feat: add add task traces function

This commit is contained in:
Eduardo Chiarotti
2025-02-10 11:50:54 -03:00
parent 2f846fc945
commit e3026ebd56

View File

@@ -80,6 +80,19 @@ class UnifiedTraceController:
self.flow_step = flow_step
self.status: str = "running"
def _add_to_task_traces(self) -> None:
"""Add this trace to the task's trace collection."""
if not hasattr(UnifiedTraceController, "_task_traces"):
UnifiedTraceController._task_traces = {}
if self.task_id is None:
return
if self.task_id not in UnifiedTraceController._task_traces:
UnifiedTraceController._task_traces[self.task_id] = []
UnifiedTraceController._task_traces[self.task_id].append(self)
@classmethod
def get_task_traces(cls, task_id: str) -> List["UnifiedTraceController"]:
"""Get all traces for a specific task.