gopidesupavan commented on PR #51085:
URL: https://github.com/apache/airflow/pull/51085#issuecomment-2910242462
Used these two dags to test.
Parent:
```
from datetime import datetime, timedelta
from airflow.providers.standard.operators.empty import EmptyOperator
from airflow.sdk import DAG
from airflow.utils.state import TaskInstanceState
from airflow.providers.standard.sensors.external_task import
ExternalTaskSensor
def ex_date(dt):
new_dt = dt - timedelta(days=1)
return new_dt
with DAG(
dag_id="external_task_sensor_parent",
start_date=datetime(2022, 3, 12, 3, 35, 0),
schedule=timedelta(days=1),
tags=["core", "sensor"],
catchup=True,
) as dag:
ets1 = ExternalTaskSensor(
task_id="check_ids",
external_dag_id="external_task_sensor_child_dag",
external_task_ids=["child_dummy1", "child_dummy2"],
allowed_states=[TaskInstanceState.SUCCESS,
TaskInstanceState.SKIPPED],
execution_delta=timedelta(minutes=7),
deferrable=True,
#execution_date_fn=ex_date,
check_existence=True,
poke_interval=20.0,
timeout=40.0,
)
ets1 >> EmptyOperator(task_id="empty1")
```
Child:
```
from datetime import datetime, timedelta
from airflow.providers.standard.operators.empty import EmptyOperator
from airflow.sdk import DAG
with DAG(
dag_id="external_task_sensor_child_dag",
start_date=datetime(2022, 3, 12, 3, 28, 0),
schedule=timedelta(days=1),
tags=["core", "sensor"],
catchup=True,
) as dag:
d0 = EmptyOperator(task_id="child_dummy1")
d2 = EmptyOperator(task_id="child_dummy2")
d0 >> d2
```
--
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]
