sunank200 commented on issue #41305:
URL: https://github.com/apache/airflow/issues/41305#issuecomment-2295405814
I have following DAG:
```
with DAG(
dag_id="dataset_produces_1",
catchup=False,
start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
schedule="@daily",
tags=["produces", "dataset-scheduled"],
) as dag1:
# [START task_outlet]
BashOperator(outlets=[dag1_dataset], task_id="producing_task_1",
bash_command="sleep 5", retries=2)
# [END task_outlet]
with DAG(
dag_id="dataset_produces_2",
catchup=False,
start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
schedule=None,
tags=["produces", "dataset-scheduled"],
) as dag2:
BashOperator(outlets=[dag2_dataset], task_id="producing_task_2",
bash_command="sleep 10")
default_args = {
'depends_on_past': True,
}
with DAG(
dag_id="conditional_dataset_and_time_based_timetable",
catchup=False,
start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
schedule=DatasetOrTimeSchedule(
timetable=CronTriggerTimetable("* * * * *", timezone="UTC"),
datasets=(dag1_dataset & dag2_dataset)
),
tags=["dataset-time-based-timetable"],
max_active_tasks=1,
default_args=default_args,
) as dag8:
BashOperator(
outlets=[Dataset("s3://dataset_time_based/dataset_other_unknown.txt")],
task_id="conditional_dataset_and_time_based_timetable",
bash_command="sleep 5",
)
```
But this runs fine for me with the correct status for each task. I am
running it locally using Breeze using a local executor. Is this correct step to
replicate this @RobbertDM ?
--
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]
