Skip to content

Commit 7c8e3d1

Browse files
commit instead of flush
1 parent 17757eb commit 7c8e3d1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cads_broker/dispatcher.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ def sync_database(self, session: sa.orm.Session) -> None:
378378
future.cancel()
379379
session = self.manage_dismissed_request(request, session)
380380
if i % 2000 == 0:
381-
session.flush()
381+
session.commit()
382382
session.commit()
383383

384384
scheduler_tasks = get_tasks_from_scheduler(self.client)

0 commit comments

Comments
 (0)