First argument must be the function + ruff

src/neo4j_graphrag/experimental/pipeline/kg_builder.py

@@ -126,6 +126,8 @@ async def run_async(
         """
         return await self.runner.run({"file_path": file_path, "text": text})
 
-    def run(self, file_path: Optional[str] = None, text: Optional[str] = None) -> PipelineResult:
+    def run(
+        self, file_path: Optional[str] = None, text: Optional[str] = None
+    ) -> PipelineResult:
         """Run pipeline synchronously"""
-        return run_sync(self, file_path=file_path, text=text)
+        return run_sync(self.run_async, file_path=file_path, text=text)

src/neo4j_graphrag/utils.py

@@ -14,10 +14,10 @@
 #  limitations under the License.
 from __future__ import annotations
 
-from functools import wraps
-from typing import Optional
 import asyncio
 import concurrent.futures
+from functools import wraps
+from typing import Optional
 
 
 def validate_search_query_input(
@@ -38,4 +38,5 @@ def async_to_sync(func):
     @wraps(func)
     def wrapper(*args, **kwargs):
         return run_sync(func, *args, **kwargs)
+
     return wrapper