fix tests in celery-library

Author: bisgaard-itis

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

@@ -103,7 +103,7 @@ async def test_submitting_task_calling_async_function_results_with_success_state
     celery_task_manager: CeleryTaskManager,
     with_celery_worker: WorkController,
 ):
-    task_filter = MyTaskFilter(user_id=42)
+    task_filter = MyTaskFilter(user_id=42, owner="test-owner")
 
     task_uuid = await celery_task_manager.submit_task(
         ExecutionMetadata(
@@ -134,7 +134,7 @@ async def test_submitting_task_with_failure_results_with_error(
     celery_task_manager: CeleryTaskManager,
     with_celery_worker: WorkController,
 ):
-    task_filter = MyTaskFilter(user_id=42)
+    task_filter = MyTaskFilter(user_id=42, owner="test-owner")
 
     task_uuid = await celery_task_manager.submit_task(
         ExecutionMetadata(
@@ -163,7 +163,7 @@ async def test_cancelling_a_running_task_aborts_and_deletes(
     celery_task_manager: CeleryTaskManager,
     with_celery_worker: WorkController,
 ):
-    task_filter = MyTaskFilter(user_id=42)
+    task_filter = MyTaskFilter(user_id=42, owner="test-owner")
 
     task_uuid = await celery_task_manager.submit_task(
         ExecutionMetadata(
@@ -186,7 +186,7 @@ async def test_listing_task_uuids_contains_submitted_task(
     celery_task_manager: CeleryTaskManager,
     with_celery_worker: WorkController,
 ):
-    task_filter = MyTaskFilter(user_id=42)
+    task_filter = MyTaskFilter(user_id=42, owner="test-owner")
 
     task_uuid = await celery_task_manager.submit_task(
         ExecutionMetadata(
@@ -215,18 +215,16 @@ async def test_filtering_listing_tasks(
     class MyFilter(OwnerMetadata):
         user_id: int
         product_name: str | Wildcard
-        client_app: str | Wildcard
 
     user_id = 42
+    _owner = "test-owner"
     expected_task_uuids: set[TaskUUID] = set()
     all_tasks: list[tuple[TaskUUID, MyFilter]] = []
 
     try:
         for _ in range(5):
             task_filter = MyFilter(
-                user_id=user_id,
-                product_name=_faker.word(),
-                client_app=_faker.word(),
+                user_id=user_id, product_name=_faker.word(), owner=_owner
             )
             task_uuid = await celery_task_manager.submit_task(
                 ExecutionMetadata(
@@ -241,7 +239,7 @@ class MyFilter(OwnerMetadata):
             task_filter = MyFilter(
                 user_id=_faker.pyint(min_value=100, max_value=200),
                 product_name=_faker.word(),
-                client_app=_faker.word(),
+                owner=_owner,
             )
             task_uuid = await celery_task_manager.submit_task(
                 ExecutionMetadata(
@@ -254,7 +252,7 @@ class MyFilter(OwnerMetadata):
         search_filter = MyFilter(
             user_id=user_id,
             product_name=Wildcard(),
-            client_app=Wildcard(),
+            owner=_owner,
         )
         tasks = await celery_task_manager.list_tasks(search_filter)
         assert expected_task_uuids == {task.uuid for task in tasks}