ephraimbuddy commented on pull request #17819:
URL: https://github.com/apache/airflow/pull/17819#issuecomment-905524522
This is how to reproduce the error: Run this dag and assert that it's
successful. Then uncomment the `depend_on_past` arg so it's proper but
`depend_on_past` instead of `depends_on_past`. You will have import error on
the UI, Run the dag and it would enter queued and retry twice before failing.
```python
import time
from datetime import datetime, timedelta
from airflow import DAG
def on_failure(ctx):
print('hello world')
print(ctx)
default_args = {'on_failure_callback': on_failure}
dag = DAG(
dag_id='Give-wrong-arg',
schedule_interval=None,
catchup=False,
start_date=datetime(2021,7,12),
default_args=default_args,
)
@dag.task(retries=2, retry_delay=timedelta(seconds=20))#,
depend_on_past=False)
def task_wrong_arg():
time.sleep(5)
@dag.task
def myfunc():
return 1
task_wrong_arg() >> myfunc()
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
