airflow.providers.common.compat.lineage.entities

Defines base entities used for providing lineage information.

Classes

File

File entity. Refers to a file.

User

User entity. Identifies a user.

Tag

Tag or classification entity.

Column

Column of a Table.

Table

Table entity.

Functions

default_if_none(arg)

Get default value when None.

Module Contents

class airflow.providers.common.compat.lineage.entities.File[source]

File entity. Refers to a file.

template_fields: ClassVar = ('url',)[source]
url: str[source]
type_hint: str | None = None[source]
class airflow.providers.common.compat.lineage.entities.User[source]

User entity. Identifies a user.

email: str[source]
first_name: str | None = None[source]
last_name: str | None = None[source]
template_fields: ClassVar = ('email', 'first_name', 'last_name')[source]
class airflow.providers.common.compat.lineage.entities.Tag[source]

Tag or classification entity.

tag_name: str[source]
template_fields: ClassVar = ('tag_name',)[source]
class airflow.providers.common.compat.lineage.entities.Column[source]

Column of a Table.

name: str[source]
description: str | None = None[source]
data_type: str[source]
tags: list[Tag] = [][source]
template_fields: ClassVar = ('name', 'description', 'data_type', 'tags')[source]
airflow.providers.common.compat.lineage.entities.default_if_none(arg)[source]

Get default value when None.

class airflow.providers.common.compat.lineage.entities.Table[source]

Table entity.

database: str[source]
cluster: str[source]
name: str[source]
tags: list[Tag] = [][source]
description: str | None = None[source]
columns: list[Column] = [][source]
owners: list[User] = [][source]
extra: dict[str, Any][source]
type_hint: str | None = None[source]
template_fields: ClassVar = ('database', 'cluster', 'name', 'tags', 'description', 'columns', 'owners', 'extra')[source]

Was this entry helpful?