File tree 1 file changed +2
-5
lines changed
test/core/pipeline/features
1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -70,15 +70,13 @@ def run_async_pipeline(
70
70
results : List [_PipelineResult ] = []
71
71
72
72
async def run_inner (data , include_outputs_from ):
73
- """Wrapper function to call pipeline.run_async method with required params."""
74
-
73
+ """Wrapper function to call pipeline.run_async method with required params."""
75
74
return await pipeline .run_async (data = data .inputs , include_outputs_from = include_outputs_from )
76
75
77
76
for data in pipeline_run_data :
78
77
try :
79
78
outputs = asyncio .run (run_inner (data , data .include_outputs_from ))
80
79
81
-
82
80
component_calls = {
83
81
(span .tags ["haystack.component.name" ], span .tags ["haystack.component.visits" ]): span .tags [
84
82
"haystack.component.input"
@@ -90,8 +88,7 @@ async def run_inner(data, include_outputs_from):
90
88
spying_tracer .spans .clear ()
91
89
except Exception as e :
92
90
return e
93
- finally :
94
- async_loop .close ()
91
+
95
92
return [e for e in zip (results , pipeline_run_data )]
96
93
97
94
You can’t perform that action at this time.
0 commit comments