base_async_handler

GalileoAsyncBaseHandler

Async Callback handler for logging traces to the Galileo platform. Arguments

_galileo_logger (GalileoLogger): The Galileo logger instance.
_nodes (dict[UUID, Node]): A dictionary of nodes, where the key is the run_id and the value is the node.
_start_new_trace (bool): Whether to start a new trace when a chain starts. Set this to False to continue using the current trace.
_flush_on_chain_end (bool): Whether to flush the trace when a chain ends.

async def async_commit(self) -> None

Commit the nodes to the trace using the Galileo Logger. Optionally flush the trace.

async def async_end_node(self, run_id: UUID, **kwargs: Any) -> None

End a node in the chain. Commit the nodes to a trace if the run_id matches the root node. Arguments

⌘I