module `lineage_mixin`

Mixin class containing Lineage specific methods To be used by OpenMetadata class

Global Variables

LINEAGE_PARSING_TIMEOUT

class `OMetaLineageMixin`

OpenMetadata API methods related to Lineage. To be inherited by OpenMetadata

method `add_lineage`

add_lineage(data: AddLineageRequest) → Dict[str, Any]

Add lineage relationship between two entities and returns the entity information of the origin node

method `add_lineage_by_query`

add_lineage_by_query(
    database_service: DatabaseService,
    sql: str,
    database_name: str = None,
    schema_name: str = None,
    timeout: int = 10
) → None

Method parses the query and generated the lineage between source and target tables

method `delete_lineage_edge`

delete_lineage_edge(edge: EntitiesEdge) → None

Remove the given Edge

method `get_lineage_by_id`

get_lineage_by_id(
    entity: Union[Type[~T], str],
    entity_id: str,
    up_depth: int = 1,
    down_depth: int = 1
) → Optional[Dict[str, Any]]

Get lineage details for an entity id Args: entity: Type of the entity entity_id: Entity ID up_depth: Upstream depth of lineage (default=1, min=0, max=3)” down_depth: Downstream depth of lineage (default=1, min=0, max=3)

method `get_lineage_by_name`

get_lineage_by_name(
    entity: Union[Type[~T], str],
    fqn: str,
    up_depth: int = 1,
    down_depth: int = 1
) → Optional[Dict[str, Any]]

Get lineage details for an entity id Args: entity: Type of the entity fqn: Entity FQN up_depth: Upstream depth of lineage (default=1, min=0, max=3)” down_depth: Downstream depth of lineage (default=1, min=0, max=3)

Ingestion Pipeline Mixin

ML Model Mixin

​module lineage_mixin

​Global Variables

​class OMetaLineageMixin

​method add_lineage

​method add_lineage_by_query

​method delete_lineage_edge

​method get_lineage_by_id

​method get_lineage_by_name