grai_source_openlineage
processor

OpenLineageProcessor Objects

class OpenLineageProcessor()

adapted_nodes

@cached_property
def adapted_nodes() -> List[SourcedNodeV1]

Arguments:

Returns:

adapted_edges

@cached_property
def adapted_edges() -> List[SourcedEdgeV1]

Arguments:

Returns:

nodes

@property
def nodes() -> List[NodeTypes]

Arguments:

Returns:

edges

@property
def edges() -> List[Edge]

Arguments:

Returns: