Example DAG demonstrating the usage of the TaskFlow API to execute Python functions natively and within a
virtual environment.
Module Contents
Functions
x()
|
|
print_context([ds])
|
Print the Airflow context and ds variable from the context. |
Attributes
-
airflow.example_dags.example_python_operator.log[source]
-
airflow.example_dags.example_python_operator.PATH_TO_PYTHON_BINARY[source]
-
airflow.example_dags.example_python_operator.BASE_DIR[source]
-
airflow.example_dags.example_python_operator.x()[source]
-
airflow.example_dags.example_python_operator.print_context(ds=None, **kwargs)[source]
Print the Airflow context and ds variable from the context.
