Skip to content

Commit 036ae36

Browse files
committed
rename TaskFilter -> OwnerMetadata
1 parent 61b9668 commit 036ae36

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

packages/celery-library/tests/unit/test_tasks.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
pytest_simcore_ops_services_selection = []
4040

4141

42-
class MyTaskFilter(OwnerMetadata):
42+
class MyOwnerMetadata(OwnerMetadata):
4343
user_id: int
4444

4545

@@ -103,7 +103,7 @@ async def test_submitting_task_calling_async_function_results_with_success_state
103103
celery_task_manager: CeleryTaskManager,
104104
with_celery_worker: WorkController,
105105
):
106-
task_filter = MyTaskFilter(user_id=42, owner="test-owner")
106+
task_filter = MyOwnerMetadata(user_id=42, owner="test-owner")
107107

108108
task_uuid = await celery_task_manager.submit_task(
109109
ExecutionMetadata(
@@ -134,7 +134,7 @@ async def test_submitting_task_with_failure_results_with_error(
134134
celery_task_manager: CeleryTaskManager,
135135
with_celery_worker: WorkController,
136136
):
137-
task_filter = MyTaskFilter(user_id=42, owner="test-owner")
137+
task_filter = MyOwnerMetadata(user_id=42, owner="test-owner")
138138

139139
task_uuid = await celery_task_manager.submit_task(
140140
ExecutionMetadata(
@@ -163,7 +163,7 @@ async def test_cancelling_a_running_task_aborts_and_deletes(
163163
celery_task_manager: CeleryTaskManager,
164164
with_celery_worker: WorkController,
165165
):
166-
task_filter = MyTaskFilter(user_id=42, owner="test-owner")
166+
task_filter = MyOwnerMetadata(user_id=42, owner="test-owner")
167167

168168
task_uuid = await celery_task_manager.submit_task(
169169
ExecutionMetadata(
@@ -186,7 +186,7 @@ async def test_listing_task_uuids_contains_submitted_task(
186186
celery_task_manager: CeleryTaskManager,
187187
with_celery_worker: WorkController,
188188
):
189-
task_filter = MyTaskFilter(user_id=42, owner="test-owner")
189+
task_filter = MyOwnerMetadata(user_id=42, owner="test-owner")
190190

191191
task_uuid = await celery_task_manager.submit_task(
192192
ExecutionMetadata(
@@ -212,18 +212,18 @@ async def test_filtering_listing_tasks(
212212
celery_task_manager: CeleryTaskManager,
213213
with_celery_worker: WorkController,
214214
):
215-
class MyFilter(OwnerMetadata):
215+
class MyOwnerMetadata(OwnerMetadata):
216216
user_id: int
217217
product_name: str | Wildcard
218218

219219
user_id = 42
220220
_owner = "test-owner"
221221
expected_task_uuids: set[TaskUUID] = set()
222-
all_tasks: list[tuple[TaskUUID, MyFilter]] = []
222+
all_tasks: list[tuple[TaskUUID, MyOwnerMetadata]] = []
223223

224224
try:
225225
for _ in range(5):
226-
task_filter = MyFilter(
226+
task_filter = MyOwnerMetadata(
227227
user_id=user_id, product_name=_faker.word(), owner=_owner
228228
)
229229
task_uuid = await celery_task_manager.submit_task(
@@ -236,7 +236,7 @@ class MyFilter(OwnerMetadata):
236236
all_tasks.append((task_uuid, task_filter))
237237

238238
for _ in range(3):
239-
task_filter = MyFilter(
239+
task_filter = MyOwnerMetadata(
240240
user_id=_faker.pyint(min_value=100, max_value=200),
241241
product_name=_faker.word(),
242242
owner=_owner,
@@ -249,7 +249,7 @@ class MyFilter(OwnerMetadata):
249249
)
250250
all_tasks.append((task_uuid, task_filter))
251251

252-
search_filter = MyFilter(
252+
search_filter = MyOwnerMetadata(
253253
user_id=user_id,
254254
product_name="*",
255255
owner=_owner,

0 commit comments

Comments
 (0)