Skip to content

Commit 44d76ff

Browse files
refactor: change name
1 parent cf92a77 commit 44d76ff

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ class CeleryTaskManager:
3737
_celery_settings: CelerySettings
3838
_task_info_store: TaskInfoStore
3939

40-
async def submit_task(
40+
async def send_task(
4141
self,
4242
task_metadata: TaskMetadata,
4343
*,
@@ -47,15 +47,15 @@ async def submit_task(
4747
with log_context(
4848
_logger,
4949
logging.DEBUG,
50-
msg=f"Submit {task_metadata.name=}: {task_context=} {task_params=}",
50+
msg=f"Send {task_metadata.name=}: {task_context=} {task_params=}",
5151
):
5252
task_uuid = uuid4()
5353
task_id = build_task_id(task_context, task_uuid)
5454
self._celery_app.send_task(
5555
task_metadata.name,
5656
task_id=task_id,
5757
kwargs={"task_id": task_id} | task_params,
58-
queue=task_metadata.queue.value,
58+
queue=task_metadata.queue,
5959
)
6060

6161
expiry = (

0 commit comments

Comments
 (0)