fix: revert expiry

giancarloromeo · giancarloromeo · commit 04d7447d5caf · 2025-09-22T16:43:03.000+02:00
diff --git a/packages/celery-library/src/celery_library/backends/redis.py b/packages/celery-library/src/celery_library/backends/redis.py
@@ -158,9 +158,6 @@ async def publish_task_event(self, task_id: TaskID, event: TaskEvent) -> None:
             stream_key,
             {"event": event.model_dump_json()},
         )
-        await self._redis_client_sdk.redis.expire(
-            stream_key, _CELERY_TASK_STREAM_EXPIRE_DEFAULT, nx=True
-        )
 
     async def consume_task_events(
         self, task_id: TaskID, last_id: str | None = None

Original file line number	Diff line number	Diff line change
`@@ -158,9 +158,6 @@ async def publish_task_event(self, task_id: TaskID, event: TaskEvent) -> None:`
`158`	`158`	`stream_key,`
`159`	`159`	`{"event": event.model_dump_json()},`
`160`	`160`	`)`
`161`		`- await self._redis_client_sdk.redis.expire(`
`162`		`- stream_key, _CELERY_TASK_STREAM_EXPIRE_DEFAULT, nx=True`
`163`		`- )`
`164`	`161`
`165`	`162`	`async def consume_task_events(`
`166`	`163`	`self, task_id: TaskID, last_id: str \| None = None`