Skip to content

Commit 16fef73

Browse files
committed
fix:saving job-model after execution
1 parent a5008a4 commit 16fef73

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

scheduler/helpers/queues/queue_logic.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ def perform_job(job_model: JobModel, connection: ConnectionType) -> Any: # noqa
4444

4545
try:
4646
result = job_model.func(*job_model.args, **job_model.kwargs)
47+
job_model.save(connection=connection, save_all=True)
4748
if asyncio.iscoroutine(result):
4849
loop = asyncio.new_event_loop()
4950
coro_result = loop.run_until_complete(result)

0 commit comments

Comments
 (0)