@@ -95,7 +95,7 @@ async def test_submitting_task_calling_async_function_results_with_success_state
9595):
9696 task_context = TaskContext (user_id = 42 )
9797
98- task_uuid = await celery_task_manager .submit_task (
98+ task_uuid = await celery_task_manager .send_task (
9999 TaskMetadata (
100100 name = fake_file_processor .__name__ ,
101101 ),
@@ -125,7 +125,7 @@ async def test_submitting_task_with_failure_results_with_error(
125125):
126126 task_context = TaskContext (user_id = 42 )
127127
128- task_uuid = await celery_task_manager .submit_task (
128+ task_uuid = await celery_task_manager .send_task (
129129 TaskMetadata (
130130 name = failure_task .__name__ ,
131131 ),
@@ -153,7 +153,7 @@ async def test_cancelling_a_running_task_aborts_and_deletes(
153153):
154154 task_context = TaskContext (user_id = 42 )
155155
156- task_uuid = await celery_task_manager .submit_task (
156+ task_uuid = await celery_task_manager .send_task (
157157 TaskMetadata (
158158 name = dreamer_task .__name__ ,
159159 ),
@@ -187,7 +187,7 @@ async def test_listing_task_uuids_contains_submitted_task(
187187):
188188 task_context = TaskContext (user_id = 42 )
189189
190- task_uuid = await celery_task_manager .submit_task (
190+ task_uuid = await celery_task_manager .send_task (
191191 TaskMetadata (
192192 name = dreamer_task .__name__ ,
193193 ),
0 commit comments