Fixing lambda

angelosantos4 · angelosantos4 · commit d9519b0610da · 2025-07-23T10:34:31.000-07:00
diff --git a/nodestream/pipeline/progress_reporter.py b/nodestream/pipeline/progress_reporter.py
@@ -68,7 +68,7 @@ def for_testing(cls, results_list: list) -> "PipelineProgressReporter":
             on_start_callback=no_op,
             on_finish_callback=no_op,
             on_fatal_error_callback=raise_exception,
-            observability_callback=lambda _: lambda record: results_list.append(record),
+            observability_callback=lambda record: results_list.append(record),
         )
 
     def report(self, index, metrics: Metrics):

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ def for_testing(cls, results_list: list) -> "PipelineProgressReporter":`
`68`	`68`	`on_start_callback=no_op,`
`69`	`69`	`on_finish_callback=no_op,`
`70`	`70`	`on_fatal_error_callback=raise_exception,`
`71`		`- observability_callback=lambda _: lambda record: results_list.append(record),`
	`71`	`+ observability_callback=lambda record: results_list.append(record),`
`72`	`72`	`)`
`73`	`73`
`74`	`74`	`def report(self, index, metrics: Metrics):`