This commit is contained in:
2023-05-20 20:35:28 +02:00
parent a600be76bf
commit a7797b6405

View File

@@ -14,7 +14,6 @@ from core.taskiq_worker import broker
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
database = app.state.database
if not database.is_connected: if not database.is_connected:
await database.connect() await database.connect()
@@ -35,7 +34,6 @@ async def lifespan(app: FastAPI):
def start_app() -> FastAPI: def start_app() -> FastAPI:
app = FastAPI(default_response_class=ORJSONResponse, lifespan=lifespan) app = FastAPI(default_response_class=ORJSONResponse, lifespan=lifespan)
app.state.database = database
app.state.redis_pool = ConnectionPool.from_url(REDIS_URL) app.state.redis_pool = ConnectionPool.from_url(REDIS_URL)
app.include_router(router) app.include_router(router)