Skip to content

Commit f1825bd

Browse files
fix: Celery task submission
1 parent 62565ba commit f1825bd

File tree

1 file changed

+13
-6
lines changed

1 file changed

+13
-6
lines changed

packages/celery-library/src/celery_library/task_manager.py

Lines changed: 13 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -50,12 +50,6 @@ async def submit_task(
5050
):
5151
task_uuid = uuid4()
5252
task_id = task_filter.create_task_id(task_uuid=task_uuid)
53-
self._celery_app.send_task(
54-
task_metadata.name,
55-
task_id=task_id,
56-
kwargs={"task_id": task_id} | task_params,
57-
queue=task_metadata.queue.value,
58-
)
5953

6054
expiry = (
6155
self._celery_settings.CELERY_EPHEMERAL_RESULT_EXPIRES
@@ -65,6 +59,19 @@ async def submit_task(
6559
await self._task_info_store.create_task(
6660
task_id, task_metadata, expiry=expiry
6761
)
62+
63+
try:
64+
self._celery_app.send_task(
65+
task_metadata.name,
66+
task_id=task_id,
67+
kwargs={"task_id": task_id} | task_params,
68+
queue=task_metadata.queue.value,
69+
)
70+
except Exception:
71+
_logger.exception("Task '%s' submission failed", task_metadata.name)
72+
await self._task_info_store.remove_task(task_id)
73+
raise
74+
6875
return task_uuid
6976

7077
async def cancel_task(self, task_filter: TaskFilter, task_uuid: TaskUUID) -> None:

0 commit comments

Comments
 (0)