remote

app/routers/take.py

@@ -3,7 +3,6 @@ import pydantic
 import typing
 
 from app.storage.mongo import tasks
-# from app.utils.configurator import configurator
 
 
 DEFAULT_RETRY_AFTER = 0.2
@@ -29,6 +28,4 @@ async def execute(queue: typing.Annotated[str, fastapi.Header()]) -> Response:
         return Response(task=None)
     if not task:
         return Response(task=None)
-    # retry_after_config = configurator.get_config('retry_after')
-    # retry_after = retry_after_config.get(queue) or retry_after_config.get('default') or DEFAULT_RETRY_AFTER
     return Response(task=Task(id=str(task._id), attempt=task.attempts, payload=task.payload))