AirflowTask

class pyatlan.model.assets.AirflowTask(*, typeName: str = 'AirflowTask', attributes: AirflowTask.Attributes = None, businessAttributes: Dict[str, Any] | None = None, createdBy: str | None = None, createTime: int | None = None, deleteHandler: str | None = None, guid: str = None, isIncomplete: bool | None = None, labels: List[str] | None = None, relationshipAttributes: RelationshipAttributes | Dict[str, Any] | None = None, status: EntityStatus | None = None, updatedBy: str | None = None, updateTime: int | None = None, version: int | None = None, classifications: List[AtlanTag] | None = None, classificationNames: List[str] | None = None, displayText: str | None = None, entityStatus: str | None = None, relationshipGuid: str | None = None, relationshipStatus: str | None = None, relationshipType: str | None = None, meaningNames: List[str] | None = None, meanings: List[Meaning] | None = None, customAttributes: Dict[str, Any] | None = None, scrubbed: bool | None = None, pendingTasks: List[str] | None = None, uniqueAttributes: Dict[str, Any] | None = None, appendRelationshipAttributes: Dict[str, Any] | None = None, removeRelationshipAttributes: Dict[str, Any] | None = None, addOrUpdateClassifications: List[AtlanTag] | None = None, removeClassifications: List[AtlanTag] | None = None, semantic: SaveSemantic | None = None, depth: int | None = None, immediateUpstream: List[LineageRef] | None = None, immediateDownstream: List[LineageRef] | None = None)

Description

AIRFLOW_DAG: ClassVar[RelationField] = <pyatlan.model.fields.atlan_fields.RelationField object>

TBC

AIRFLOW_DAG_NAME: ClassVar[KeywordTextField] = <pyatlan.model.fields.atlan_fields.KeywordTextField object>

Simple name of the DAG this task is contained within.

AIRFLOW_DAG_QUALIFIED_NAME: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>

Unique name of the DAG this task is contained within.

AIRFLOW_TASK_CONNECTION_ID: ClassVar[KeywordTextField] = <pyatlan.model.fields.atlan_fields.KeywordTextField object>

Identifier for the connection this task accesses.

AIRFLOW_TASK_GROUP_NAME: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>

Group name for the task.

AIRFLOW_TASK_OPERATOR_CLASS: ClassVar[KeywordTextField] = <pyatlan.model.fields.atlan_fields.KeywordTextField object>

Class name for the operator this task uses.

AIRFLOW_TASK_POOL: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>

Pool on which this run happened.

AIRFLOW_TASK_POOL_SLOTS: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>

Pool slots used for the run.

AIRFLOW_TASK_PRIORITY_WEIGHT: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>

Priority of the run.

AIRFLOW_TASK_QUEUE: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>

Queue on which this run happened.

AIRFLOW_TASK_RETRY_NUMBER: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>

Retry count for this task running.

AIRFLOW_TASK_SQL: ClassVar[TextField] = <pyatlan.model.fields.atlan_fields.TextField object>

SQL code that executes through this task.

AIRFLOW_TASK_TRIGGER_RULE: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>

Trigger for the run.

INPUTS: ClassVar[RelationField] = <pyatlan.model.fields.atlan_fields.RelationField object>

TBC

OUTPUTS: ClassVar[RelationField] = <pyatlan.model.fields.atlan_fields.RelationField object>

TBC

PROCESS: ClassVar[RelationField] = <pyatlan.model.fields.atlan_fields.RelationField object>

TBC