Skip to content
This repository was archived by the owner on May 22, 2025. It is now read-only.

Latest commit

 

History

History
54 lines (45 loc) · 2.42 KB

File metadata and controls

54 lines (45 loc) · 2.42 KB

Task

For details see: airflow.models.baseoperator.BaseOperator

Properties

Name Type Description Notes
class_ref ClassReference [optional]
task_id str [optional] [readonly]
task_display_name str [optional] [readonly]
owner str [optional] [readonly]
start_date datetime [optional] [readonly]
end_date datetime [optional] [readonly]
trigger_rule TriggerRule [optional]
extra_links List[TaskExtraLinksInner] [optional] [readonly]
depends_on_past bool [optional] [readonly]
is_mapped bool [optional] [readonly]
wait_for_downstream bool [optional] [readonly]
retries float [optional] [readonly]
queue str [optional] [readonly]
pool str [optional] [readonly]
pool_slots float [optional] [readonly]
execution_timeout TimeDelta [optional]
retry_delay TimeDelta [optional]
retry_exponential_backoff bool [optional] [readonly]
priority_weight float [optional] [readonly]
weight_rule WeightRule [optional]
ui_color str Color in hexadecimal notation. [optional]
ui_fgcolor str Color in hexadecimal notation. [optional]
template_fields List[str] [optional] [readonly]
sub_dag DAG [optional]
downstream_task_ids List[str] [optional] [readonly]

Example

from titanium_airflow_client.models.task import Task

# TODO update the JSON string below
json = "{}"
# create an instance of Task from a JSON string
task_instance = Task.from_json(json)
# print the JSON string representation of the object
print(Task.to_json())

# convert the object into a dict
task_dict = task_instance.to_dict()
# create an instance of Task from a dict
task_from_dict = Task.from_dict(task_dict)

[Back to Model list] [Back to API list] [Back to README]