update pagination

getzep · Nov 19, 2024 · d0d93bb · d0d93bb
1 parent 3841e2b
commit d0d93bb
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/graphiti_core/edges.py b/graphiti_core/edges.py
@@ -144,7 +144,7 @@ async def get_by_group_ids(
         limit: int = DEFAULT_PAGE_LIMIT,
         created_at: datetime = None,
     ):
-        cursor_query: LiteralString = 'AND e.uuid < $created_at' if created_at else ''
+        cursor_query: LiteralString = 'AND e.created_at < $created_at' if created_at else ''
 
         records, _, _ = await driver.execute_query(
             """
@@ -296,7 +296,7 @@ async def get_by_group_ids(
         limit: int = DEFAULT_PAGE_LIMIT,
         created_at: datetime = None,
     ):
-        cursor_query: LiteralString = 'AND e.uuid < $created_at' if created_at else ''
+        cursor_query: LiteralString = 'AND e.created_at < $created_at' if created_at else ''
 
         records, _, _ = await driver.execute_query(
             """
@@ -402,7 +402,7 @@ async def get_by_group_ids(
         limit: int = DEFAULT_PAGE_LIMIT,
         created_at: datetime = None,
     ):
-        cursor_query: LiteralString = 'AND e.uuid < $created_at' if created_at else ''
+        cursor_query: LiteralString = 'AND e.created_at < $created_at' if created_at else ''
 
         records, _, _ = await driver.execute_query(
             """

diff --git a/graphiti_core/nodes.py b/graphiti_core/nodes.py
@@ -214,7 +214,7 @@ async def get_by_group_ids(
         limit: int = DEFAULT_PAGE_LIMIT,
         created_at: datetime = None,
     ):
-        cursor_query: LiteralString = 'AND e.uuid < $created_at' if created_at else ''
+        cursor_query: LiteralString = 'AND e.created_at < $created_at' if created_at else ''
 
         records, _, _ = await driver.execute_query(
             """
@@ -330,7 +330,7 @@ async def get_by_group_ids(
         limit: int = DEFAULT_PAGE_LIMIT,
         created_at: datetime = None,
     ):
-        cursor_query: LiteralString = 'AND e.uuid < $created_at' if created_at else ''
+        cursor_query: LiteralString = 'AND n.created_at < $created_at' if created_at else ''
 
         records, _, _ = await driver.execute_query(
             """
@@ -444,7 +444,7 @@ async def get_by_group_ids(
         limit: int = DEFAULT_PAGE_LIMIT,
         created_at: datetime = None,
     ):
-        cursor_query: LiteralString = 'AND e.uuid < $created_at' if created_at else ''
+        cursor_query: LiteralString = 'AND n.created_at < $created_at' if created_at else ''
 
         records, _, _ = await driver.execute_query(
             """