task_metadata -> execution_metadata

Author: bisgaard-itis

packages/celery-library/src/celery_library/backends/redis.py

@@ -35,15 +35,15 @@ def __init__(self, redis_client_sdk: RedisClientSDK) -> None:
     async def create_task(
         self,
         task_id: TaskID,
-        task_metadata: ExecutionMetadata,
+        execution_metadata: ExecutionMetadata,
         expiry: timedelta,
     ) -> None:
         task_key = _build_key(task_id)
         await handle_redis_returns_union_types(
             self._redis_client_sdk.redis.hset(
                 name=task_key,
                 key=_CELERY_TASK_METADATA_KEY,
-                value=task_metadata.model_dump_json(),
+                value=execution_metadata.model_dump_json(),
             )
         )
         await self._redis_client_sdk.redis.expire(
@@ -112,11 +112,11 @@ async def list_tasks(self, owner_metadata: OwnerMetadata) -> list[Task]:
                 continue
 
             with contextlib.suppress(ValidationError):
-                task_metadata = ExecutionMetadata.model_validate_json(raw_metadata)
+                execution_metadata = ExecutionMetadata.model_validate_json(raw_metadata)
                 tasks.append(
                     Task(
                         uuid=OwnerMetadata.get_task_uuid(key),
-                        metadata=task_metadata,
+                        metadata=execution_metadata,
                     )
                 )
 

packages/service-library/src/servicelib/celery/models.py

@@ -179,7 +179,7 @@ class TaskInfoStore(Protocol):
     async def create_task(
         self,
         task_id: TaskID,
-        task_metadata: ExecutionMetadata,
+        execution_metadata: ExecutionMetadata,
         expiry: datetime.timedelta,
     ) -> None: ...