We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 02ae9da commit daf3447Copy full SHA for daf3447
packages/service-library/src/servicelib/fastapi/celery/app_server.py
@@ -9,6 +9,7 @@
9
from ...celery.app_server import BaseAppServer
10
from ...celery.task_manager import TaskManager
11
12
+_STARTUP_TIMEOUT: Final[float] = datetime.timedelta(minutes=5).total_seconds()
13
_SHUTDOWN_TIMEOUT: Final[float] = datetime.timedelta(seconds=10).total_seconds()
14
15
_logger = logging.getLogger(__name__)
@@ -27,7 +28,7 @@ async def run_until_shutdown(
27
28
) -> None:
29
async with LifespanManager(
30
self.app,
- startup_timeout=None, # waits for full app initialization (DB migrations, etc.)
31
+ startup_timeout=_STARTUP_TIMEOUT,
32
shutdown_timeout=_SHUTDOWN_TIMEOUT,
33
):
34
_logger.info("FastAPI initialized: %s", self.app)
0 commit comments