pool = None
async def startup_event():
global pool
logging.info("Startup event: Initializing database pool")
pool = await asyncpg.create_pool(os.getenv('DATABASE_URL'))
logging.info(f"Startup event: Database pool initialized: {pool}")
async def shutdown_event():
global pool
logging.info("Shutdown event: Initiated")
if pool:
logging.info("Shutdown event: Closing database pool")
await pool.close()
logging.info("Shutdown event: Database pool closed")
app = FastAPI()
app.add_event_handler("startup", startup_event)
app.add_event_handler("shutdown", shutdown_event)
pool = None
async def startup_event():
global pool
logging.info("Startup event: Initializing database pool")
pool = await asyncpg.create_pool(os.getenv('DATABASE_URL'))
logging.info(f"Startup event: Database pool initialized: {pool}")
async def shutdown_event():
global pool
logging.info("Shutdown event: Initiated")
if pool:
logging.info("Shutdown event: Closing database pool")
await pool.close()
logging.info("Shutdown event: Database pool closed")
app = FastAPI()
app.add_event_handler("startup", startup_event)
app.add_event_handler("shutdown", shutdown_event)