We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 20e66ba commit 8c79ddeCopy full SHA for 8c79dde
packages/service-library/src/servicelib/deferred_tasks/_deferred_manager.py
@@ -305,10 +305,11 @@ async def __start(
305
state=TaskState.SCHEDULED,
306
)
307
308
+ await self._task_tracker.save(task_uid, task_schedule)
309
+
310
with log_catch(_logger, reraise=False):
311
await subclass.on_created(task_uid, deferred_context)
312
- await self._task_tracker.save(task_uid, task_schedule)
313
_logger.debug("Scheduled task '%s' with entry: %s", task_uid, task_schedule)
314
await self.__publish_to_queue(task_uid, _FastStreamRabbitQueue.SCHEDULED)
315
0 commit comments