From bb42cc2f52846b56cd862eb0af2d1faad0abd298 Mon Sep 17 00:00:00 2001 From: Job Almekinders <55230856+job-almekinders@users.noreply.github.com> Date: Mon, 5 Feb 2024 15:02:30 +0100 Subject: [PATCH] Add conn.commit() to Postgresonline_write_batch.online_write_batch Signed-off-by: Job Almekinders <55230856+job-almekinders@users.noreply.github.com> --- sdk/python/feast/infra/online_stores/contrib/postgres.py | 1 + 1 file changed, 1 insertion(+) diff --git a/sdk/python/feast/infra/online_stores/contrib/postgres.py b/sdk/python/feast/infra/online_stores/contrib/postgres.py index a12e66f109..49f87ddb0a 100644 --- a/sdk/python/feast/infra/online_stores/contrib/postgres.py +++ b/sdk/python/feast/infra/online_stores/contrib/postgres.py @@ -99,6 +99,7 @@ def online_write_batch( cur_batch, page_size=batch_size, ) + conn.commit() if progress: progress(len(cur_batch))