jedcunningham commented on issue #17238:
URL: https://github.com/apache/airflow/issues/17238#issuecomment-890121751
I've tried to replicate this with the following DAG without success:
```
import time
from datetime import datetime
from airflow import DAG
from airflow.operators.dummy import DummyOperator
from airflow.operators.python import PythonOperator
default_args = {"start_date": datetime(2021, 7, 30)}
with DAG("skipped", default_args=default_args, schedule_interval=None) as
dag:
start = DummyOperator(task_id="start")
end = DummyOperator(task_id="end")
for i in range(5):
prev = start
for j in range(3):
t = PythonOperator(
task_id=f"t-{i}-{j}", python_callable=lambda: time.sleep(10)
)
prev >> t
prev = t
t >> end
```
@mgorsk1, any chance you could try in your instance with that DAG? Also,
filtering down to the pod name might be missing an important log message. I'd
try filtering by a unique task_id (if there is one) too.
--
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]
