wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixing ruff format.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-09-26 10:49:52 -03:00
parent b3a84fc772
commit 4d1915eb41
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/pipecat/runner/run.py
View File

@@ -235,21 +235,21 @@ def _setup_webrtc_routes(app: FastAPI, esp32_mode: bool = False, host: str = "lo
def _add_lifespan_to_app(app: FastAPI, new_lifespan): def _add_lifespan_to_app(app: FastAPI, new_lifespan):
"""Add a new lifespan context manager to the app, combining with existing if present. """Add a new lifespan context manager to the app, combining with existing if present.
Args: Args:
app: The FastAPI application instance app: The FastAPI application instance
new_lifespan: The new lifespan context manager to add new_lifespan: The new lifespan context manager to add
""" """
if hasattr(app.router, 'lifespan_context') and app.router.lifespan_context is not None: if hasattr(app.router, "lifespan_context") and app.router.lifespan_context is not None:
# If there's already a lifespan context, combine them # If there's already a lifespan context, combine them
existing_lifespan = app.router.lifespan_context existing_lifespan = app.router.lifespan_context
@asynccontextmanager @asynccontextmanager
async def combined_lifespan(app: FastAPI): async def combined_lifespan(app: FastAPI):
async with existing_lifespan(app): async with existing_lifespan(app):
async with new_lifespan(app): async with new_lifespan(app):
yield yield
app.router.lifespan_context = combined_lifespan app.router.lifespan_context = combined_lifespan
else: else:
# No existing lifespan, use the new one # No existing lifespan, use the new one
@@ -306,7 +306,7 @@ def _setup_whatsapp_routes(app: FastAPI):
if whatsapp_client is None: if whatsapp_client is None:
logger.error("WhatsApp client is not initialized") logger.error("WhatsApp client is not initialized")
raise HTTPException(status_code=503, detail="Service unavailable") raise HTTPException(status_code=503, detail="Service unavailable")
params = dict(request.query_params) params = dict(request.query_params)
logger.debug(f"Webhook verification request received with params: {list(params.keys())}") logger.debug(f"Webhook verification request received with params: {list(params.keys())}")
@@ -334,7 +334,7 @@ def _setup_whatsapp_routes(app: FastAPI):
if whatsapp_client is None: if whatsapp_client is None:
logger.error("WhatsApp client is not initialized") logger.error("WhatsApp client is not initialized")
raise HTTPException(status_code=503, detail="Service unavailable") raise HTTPException(status_code=503, detail="Service unavailable")
# Validate webhook object type # Validate webhook object type
if body.object != "whatsapp_business_account": if body.object != "whatsapp_business_account":
logger.warning(f"Invalid webhook object type: {body.object}") logger.warning(f"Invalid webhook object type: {body.object}")
@@ -687,4 +687,4 @@ def main():
if __name__ == "__main__": if __name__ == "__main__":
main() main()