diff --git a/src/docket/worker.py b/src/docket/worker.py index 97f04fcf..2c739482 100644 --- a/src/docket/worker.py +++ b/src/docket/worker.py @@ -286,7 +286,7 @@ async def get_new_deliveries(redis: Redis) -> RedisReadGroupResponse: count=available_slots, ) - async def start_task(message_id: RedisMessageID, message: RedisMessage) -> bool: + def start_task(message_id: RedisMessageID, message: RedisMessage) -> bool: function_name = message[b"function"].decode() if not (function := self.docket.tasks.get(function_name)): logger.warning( @@ -347,7 +347,7 @@ async def ack_message(redis: Redis, message_id: RedisMessageID) -> None: if not message: # pragma: no cover continue - task_started = await start_task(message_id, message) + task_started = start_task(message_id, message) if not task_started: # Other errors - delete and ack await self._delete_known_task(redis, message)