how this pythonoperator task fail ?? #60503
Unanswered
assadali007
asked this question in
General
Replies: 1 comment
-
|
I guess you are using some super-old example - days_ago should never be used in start_date, also likely in Airflow 3 context has changed - we are using logical_date for a long while. You have forgotten to mention your Airflow version, but I guess you should look at details of context and examples in the docs of Airflow you are using. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
i run this code manually trigger i follow the code example in the picture said if no value is set it will fail i provided no value i not fail the execution is None my question how it fail ??
`dag = DAG(
dag_id='chapter4_print_context',
start_date = airflow.utils.dates.days_ago(3),
schedule_interval ="@daily"
)
def _print_context(execution_date,**context):
print(execution_date)
print_context = PythonOperator(

task_id ="print_context",
python_callable=_print_context,
dag=dag
)`
Beta Was this translation helpful? Give feedback.
All reactions