ruff

stellasia · stellasia · commit e48269cc61f9 · 2025-12-11T10:39:55.000+01:00
diff --git a/src/neo4j_graphrag/experimental/pipeline/pipeline.py b/src/neo4j_graphrag/experimental/pipeline/pipeline.py
@@ -581,6 +581,7 @@ async def _run(self, run_id: str, data: dict[str, Any]) -> PipelineResult:
             result=await self.get_final_results(orchestrator.run_id),
         )
         await self.event_notifier.notify_pipeline_finished(
-            run_id, await self.get_final_results(run_id),
+            run_id,
+            await self.get_final_results(run_id),
         )
         return result

Original file line number	Diff line number	Diff line change
`@@ -581,6 +581,7 @@ async def _run(self, run_id: str, data: dict[str, Any]) -> PipelineResult:`
`581`	`581`	`result=await self.get_final_results(orchestrator.run_id),`
`582`	`582`	`)`
`583`	`583`	`await self.event_notifier.notify_pipeline_finished(`
`584`		`- run_id, await self.get_final_results(run_id),`
	`584`	`+ run_id,`
	`585`	`+ await self.get_final_results(run_id),`
`585`	`586`	`)`
`586`	`587`	`return result`