From 90226d30128c07e4284ecff56a4b89f684f90010 Mon Sep 17 00:00:00 2001
From: Gabriel Luiz Freitas Almeida <gabriel@langflow.org>
Date: Thu, 15 May 2025 17:43:01 -0300
Subject: [PATCH] chore: Consistent use of apaginate and update
 fastapi-pagination version (#8037)

* chore: update fastapi-pagination dependency version to 0.13.1 in project files

* fix: replace paginate with apaginate in flow, monitor, and project modules for consistency
---
 src/backend/base/langflow/api/v1/flows.py   | 4 ++--
 src/backend/base/langflow/api/v1/monitor.py | 4 ++--
 src/backend/base/pyproject.toml             | 2 +-
 uv.lock                                     | 2 +-
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/backend/base/langflow/api/v1/flows.py b/src/backend/base/langflow/api/v1/flows.py
index 531ae888d..742ac42ac 100644
--- a/src/backend/base/langflow/api/v1/flows.py
+++ b/src/backend/base/langflow/api/v1/flows.py
@@ -15,7 +15,7 @@ from fastapi import APIRouter, Depends, File, HTTPException, Response, UploadFil
 from fastapi.encoders import jsonable_encoder
 from fastapi.responses import StreamingResponse
 from fastapi_pagination import Page, Params
-from fastapi_pagination.ext.sqlalchemy import paginate
+from fastapi_pagination.ext.sqlalchemy import apaginate
 from sqlmodel import and_, col, select
 from sqlmodel.ext.asyncio.session import AsyncSession
 
@@ -247,7 +247,7 @@ async def read_flows(
             return compress_response(flows)
 
         stmt = stmt.where(Flow.folder_id == folder_id)
-        return await paginate(session, stmt, params=params)
+        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 718f426f4..9ff5b11ce 100644
--- a/src/backend/base/langflow/api/v1/monitor.py
+++ b/src/backend/base/langflow/api/v1/monitor.py
@@ -3,7 +3,7 @@ from uuid import UUID
 
 from fastapi import APIRouter, Depends, HTTPException, Query
 from fastapi_pagination import Page, Params
-from fastapi_pagination.ext.sqlmodel import paginate
+from fastapi_pagination.ext.sqlmodel import apaginate
 from sqlalchemy import delete
 from sqlmodel import col, select
 
@@ -171,6 +171,6 @@ async def get_transactions(
             .where(TransactionTable.flow_id == flow_id)
             .order_by(col(TransactionTable.timestamp))
         )
-        return await paginate(session, stmt, params=params, transformer=transform_transaction_table)
+        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/pyproject.toml b/src/backend/base/pyproject.toml
index cb9c1ce4d..27850c3a9 100644
--- a/src/backend/base/pyproject.toml
+++ b/src/backend/base/pyproject.toml
@@ -72,7 +72,7 @@ dependencies = [
     "diskcache>=5.6.3,<6.0.0",
     "clickhouse-connect==0.7.19",
     "assemblyai>=0.33.0,<1.0.0",
-    "fastapi-pagination>=0.12.29,<1.0.0",
+    "fastapi-pagination>=0.13.1,<1.0.0",
     "defusedxml>=0.7.1,<1.0.0",
     "pypdf~=5.1.0",
     "validators>=0.34.0",
diff --git a/uv.lock b/uv.lock
index 252ae6198..fbab2c4d4 100644
--- a/uv.lock
+++ b/uv.lock
@@ -5146,7 +5146,7 @@ requires-dist = [
     { name = "elevenlabs", specifier = ">=1.54.0" },
     { name = "emoji", specifier = ">=2.12.0,<3.0.0" },
     { name = "fastapi", specifier = ">=0.115.2,<1.0.0" },
-    { name = "fastapi-pagination", specifier = ">=0.12.29,<1.0.0" },
+    { name = "fastapi-pagination", specifier = ">=0.13.1,<1.0.0" },
     { name = "filelock", specifier = ">=3.15.4,<4.0.0" },
     { name = "firecrawl-py", specifier = ">=1.0.16,<2.0.0" },
     { name = "flower", marker = "extra == 'all'", specifier = ">=1.0.0" },