File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -175,6 +175,7 @@ def _export_prompt(
175175 # Parent Log in Trace upload failed
176176 file_path = read_from_opentelemetry_span (span , key = HL_PATH_KEY )
177177 logger .error (f"Skipping log for { file_path } : parent Log upload failed" )
178+ return
178179 else :
179180 trace_parent_id = None
180181 prompt : PromptKernelRequestParams = file_object ["prompt" ]
@@ -220,6 +221,7 @@ def _export_tool(
220221 # Parent Log in Trace upload failed
221222 file_path = read_from_opentelemetry_span (span , key = HL_PATH_KEY )
222223 logger .error (f"Skipping log for { file_path } : parent Log upload failed" )
224+ return
223225 else :
224226 trace_parent_id = None
225227 tool = file_object ["tool" ]
@@ -249,7 +251,6 @@ def _export_tool(
249251 logger .error (str (e ))
250252 self ._span_id_to_uploaded_log_id [span .context .span_id ] = None
251253
252-
253254 def _export_flow (
254255 self ,
255256 span : ReadableSpan ,
@@ -269,6 +270,7 @@ def _export_flow(
269270 # Parent Log in Trace upload failed
270271 file_path = read_from_opentelemetry_span (span , key = HL_PATH_KEY )
271272 logger .error (f"Skipping log for { file_path } : parent Log upload failed" )
273+ return
272274 else :
273275 trace_parent_id = None
274276 flow : FlowKernelRequestParams
You can’t perform that action at this time.
0 commit comments