We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 4097592 + ccf164e commit 20f82d4Copy full SHA for 20f82d4
fq_server/server.py
@@ -83,7 +83,7 @@ async def requeue_with_lock(self):
83
@asynccontextmanager
84
async def _lifespan(self, app: Starlette):
85
# --- startup ---
86
- await self.queue._initialize()
+ await self.queue.initialize()
87
# mimic original behavior: use requeue_with_lock loop
88
self._requeue_task = asyncio.create_task(self.requeue_with_lock())
89
0 commit comments