Skip to content

Commit

Permalink
move update database
Browse files Browse the repository at this point in the history
  • Loading branch information
wxtim committed Aug 1, 2023
1 parent 9a57fd9 commit 2791e5a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cylc/flow/scheduler.py
Original file line number Diff line number Diff line change
Expand Up @@ -1775,6 +1775,8 @@ async def main_loop(self) -> None:
with suppress(KeyError):
self.timers[self.EVENT_STALL_TIMEOUT].stop()

# Database update
self.workflow_db_mgr.put_task_pool(self.pool)
self.update_data_store()

self.process_workflow_db_queue()
Expand Down Expand Up @@ -1859,8 +1861,6 @@ async def update_data_structure(self, reloaded: bool = False):
# Non-async sleep - yield to other threads rather
# than event loop
sleep(0)
# Database update
self.workflow_db_mgr.put_task_pool(self.pool)

def check_workflow_timers(self):
"""Check timers, and abort or run event handlers as configured."""
Expand Down

0 comments on commit 2791e5a

Please sign in to comment.