From 5e1b74d43f1e07acb972dea64bfb2b9cf5ed03d5 Mon Sep 17 00:00:00 2001 From: Jordan Frazier <122494242+jordanrfrazier@users.noreply.github.com> Date: Tue, 20 May 2025 10:01:05 -0700 Subject: [PATCH] fix: suppresses fastapi-pagination warnings (#8121) * Suppresses fastapi-pagination warnings * [autofix.ci] apply automated fixes --------- Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com> Co-authored-by: Deon Sanchez <69873175+deon-sanchez@users.noreply.github.com> --- src/backend/base/langflow/api/v1/flows.py | 9 ++++++++- src/backend/base/langflow/api/v1/monitor.py | 8 +++++++- src/backend/base/langflow/api/v1/projects.py | 8 +++++++- 3 files changed, 22 insertions(+), 3 deletions(-) diff --git a/src/backend/base/langflow/api/v1/flows.py b/src/backend/base/langflow/api/v1/flows.py index e7742ac00..6c9a45b81 100644 --- a/src/backend/base/langflow/api/v1/flows.py +++ b/src/backend/base/langflow/api/v1/flows.py @@ -247,7 +247,14 @@ async def read_flows( return compress_response(flows) stmt = stmt.where(Flow.folder_id == folder_id) - return await apaginate(session, stmt, params=params) + + import warnings + + with warnings.catch_warnings(): + warnings.filterwarnings( + "ignore", category=DeprecationWarning, module=r"fastapi_pagination\.ext\.sqlalchemy" + ) + return await apaginate(session, stmt, params=params) except Exception as e: raise HTTPException(status_code=500, detail=str(e)) from e diff --git a/src/backend/base/langflow/api/v1/monitor.py b/src/backend/base/langflow/api/v1/monitor.py index 9ff5b11ce..6658c1cb5 100644 --- a/src/backend/base/langflow/api/v1/monitor.py +++ b/src/backend/base/langflow/api/v1/monitor.py @@ -171,6 +171,12 @@ async def get_transactions( .where(TransactionTable.flow_id == flow_id) .order_by(col(TransactionTable.timestamp)) ) - return await apaginate(session, stmt, params=params, transformer=transform_transaction_table) + import warnings + + with warnings.catch_warnings(): + warnings.filterwarnings( + "ignore", category=DeprecationWarning, module=r"fastapi_pagination\.ext\.sqlalchemy" + ) + return await apaginate(session, stmt, params=params, transformer=transform_transaction_table) except Exception as e: raise HTTPException(status_code=500, detail=str(e)) from e diff --git a/src/backend/base/langflow/api/v1/projects.py b/src/backend/base/langflow/api/v1/projects.py index 5626e61b6..19c33bef5 100644 --- a/src/backend/base/langflow/api/v1/projects.py +++ b/src/backend/base/langflow/api/v1/projects.py @@ -152,7 +152,13 @@ async def read_project( stmt = stmt.where(Flow.is_component == False) # noqa: E712 if search: stmt = stmt.where(Flow.name.like(f"%{search}%")) # type: ignore[attr-defined] - paginated_flows = await apaginate(session, stmt, params=params) + import warnings + + with warnings.catch_warnings(): + warnings.filterwarnings( + "ignore", category=DeprecationWarning, module=r"fastapi_pagination\.ext\.sqlalchemy" + ) + paginated_flows = await apaginate(session, stmt, params=params) return FolderWithPaginatedFlows(folder=FolderRead.model_validate(project), flows=paginated_flows)