Skip to content

Commit de7a36d

Browse files
committed
commit just after creating the dataset
1 parent 3a0a9d0 commit de7a36d

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

  • functions-python/batch_process_dataset/src

functions-python/batch_process_dataset/src/main.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,9 +238,13 @@ def create_dataset(self, dataset_file: DatasetFile, db_session: Session):
238238
latest_dataset.latest = False
239239
db_session.add(latest_dataset)
240240
db_session.add(new_dataset)
241+
db_session.commit()
242+
logging.info(f"[{self.feed_stable_id}] Dataset created successfully.")
241243

242244
refresh_materialized_view(db_session, t_feedsearch.name)
243-
logging.info(f"[{self.feed_stable_id}] Dataset created successfully.")
245+
logging.info(
246+
f"[{self.feed_stable_id}] Materialized view refresh event triggered successfully."
247+
)
244248
except Exception as e:
245249
raise Exception(f"Error creating dataset: {e}")
246250

0 commit comments

Comments
 (0)