File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -745,8 +745,8 @@ def record_output(self, output: Any):
745
745
asyncio .create_task (self ._update_coroutine (span , output , "output" ))
746
746
747
747
# # Queue span with output data (unless it's pending)
748
- # if self.background_span_service and not inspect.iscoroutine(output):
749
- # self.background_span_service.queue_span(span, span_state="output")
748
+ if self .background_span_service and not inspect .iscoroutine (output ):
749
+ self .background_span_service .queue_span (span , span_state = "output" )
750
750
751
751
return span # Return the created entry
752
752
# Removed else block - original didn't have one
@@ -1005,6 +1005,7 @@ def _worker_loop(self):
1005
1005
pending_task_count = 0 # Track how many tasks we've taken from queue but not marked done
1006
1006
1007
1007
while not self ._shutdown_event .is_set ():
1008
+ # print(f"Worker loop queue size: {self._span_queue.qsize()}")
1008
1009
try :
1009
1010
# Try to get a span with timeout
1010
1011
try :
You can’t perform that action at this time.
0 commit comments