Skip to main content

​
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_commit

async def async_commit(self) -> None
Commit the nodes to the trace using the Galileo Logger. Optionally flush the trace.

​
async_end_node

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
  • run_id (UUID): The run ID.
  • **kwargs (Any): Additional parameters to update the span with.