File tree Expand file tree Collapse file tree 2 files changed +8
-3
lines changed
services/storage/tests/unit/modules/celery Expand file tree Collapse file tree 2 files changed +8
-3
lines changed Original file line number Diff line number Diff line change 1+ # pylint:disable=redefined-outer-name
2+ # pylint:disable=unused-argument
3+
14from collections .abc import Callable , Iterable
25from datetime import timedelta
36from typing import Any
Original file line number Diff line number Diff line change @@ -90,7 +90,7 @@ async def test_submitting_task_calling_async_function_results_with_success_state
9090 task_context = TaskContext (user_id = 42 )
9191
9292 task_uuid = await celery_client .send_task (
93- " sync_archive" ,
93+ sync_archive . __name__ ,
9494 task_context = task_context ,
9595 files = [f"file{ n } " for n in range (5 )],
9696 )
@@ -118,7 +118,9 @@ async def test_submitting_task_with_failure_results_with_error(
118118):
119119 task_context = TaskContext (user_id = 42 )
120120
121- task_uuid = await celery_client .send_task ("failure_task" , task_context = task_context )
121+ task_uuid = await celery_client .send_task (
122+ failure_task .__name__ , task_context = task_context
123+ )
122124
123125 for attempt in Retrying (
124126 retry = retry_if_exception_type ((AssertionError , ValidationError )),
@@ -145,7 +147,7 @@ async def test_aborting_task_results_with_aborted_state(
145147 task_context = TaskContext (user_id = 42 )
146148
147149 task_uuid = await celery_client .send_task (
148- " dreamer_task" ,
150+ dreamer_task . __name__ ,
149151 task_context = task_context ,
150152 )
151153
You can’t perform that action at this time.
0 commit comments