GalileoAsyncBaseHandler Objects

class GalileoAsyncBaseHandler(GalileoBaseHandler)
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() -> None
Commit the nodes to the trace using the Galileo Logger. Optionally flush the trace.

async_end_node

async def async_end_node(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.