diff --git a/changelog/fixed.md b/changelog/fixed.md
new file mode 100644
index 00000000..ec53c282
--- /dev/null
+++ b/changelog/fixed.md
@@ -0,0 +1 @@
+Fixes using of parallel with filters for Infrahub Client Sync
diff --git a/infrahub_sdk/client.py b/infrahub_sdk/client.py
index dc1f539f..a95ac5a4 100644
--- a/infrahub_sdk/client.py
+++ b/infrahub_sdk/client.py
@@ -1946,9 +1946,10 @@ def filters(
         """
         branch = branch or self.default_branch
         schema = self.schema.get(kind=kind, branch=branch)
-        node = InfrahubNodeSync(client=self, schema=schema, branch=branch)
         if at:
             at = Timestamp(at)
+
+        node = InfrahubNodeSync(client=self, schema=schema, branch=branch)
         filters = kwargs
         pagination_size = self.pagination_size
 
@@ -2012,7 +2013,7 @@ def process_non_batch() -> tuple[list[InfrahubNodeSync], list[InfrahubNodeSync]]
 
             while has_remaining_items:
                 page_offset = (page_number - 1) * pagination_size
-                response, process_result = process_page(page_offset, page_number)
+                response, process_result = process_page(page_offset=page_offset, page_number=page_number)
 
                 nodes.extend(process_result["nodes"])
                 related_nodes.extend(process_result["related_nodes"])
diff --git a/infrahub_sdk/node/node.py b/infrahub_sdk/node/node.py
index bad53aca..f69c6231 100644
--- a/infrahub_sdk/node/node.py
+++ b/infrahub_sdk/node/node.py
@@ -402,10 +402,10 @@ def generate_query_data_init(
         if order:
             data["@filters"]["order"] = order
 
-        if offset:
+        if offset is not None:
             data["@filters"]["offset"] = offset
 
-        if limit:
+        if limit is not None:
             data["@filters"]["limit"] = limit
 
         if include and exclude: