Я использую ExternalTaskSensor, и задача просто продолжает тыкать ⇐ Python

[Anonymous]

У меня есть две группы обеспечения доступности баз данных для тестирования использования ExternalTaskSensor
Однако задача ExternalTaskSensortask просто продолжает говорить «Poking» и не завершает работу.
Что такое может быть?
введите здесь описание изображения
Это мои группы обеспечения доступности баз данных:

Код: Выделить всё

from datetime import timedelta, datetime
import pendulum
from airflow.models import DAG
from airflow.operators.bash import BashOperator
from airflow.operators.empty import EmptyOperator

dag_id = 'teste_dagA'

default_args = {
'owner': 'Engineering',
'retries': 2,
'retry_delay': timedelta(minutes=1),
'depends_on_past': False,
'email_on_failure': False,
'email_on_retry': False,
}

with DAG(
dag_id=dag_id,
tags=['teste', 'lakehouse', 'mediator'],
default_args=default_args,
description='teste',
schedule_interval=timedelta(minutes=3),
start_date=datetime(2025, 1, 15,0,0,0),
catchup=False,
) as dag:

empty_start_task = EmptyOperator(task_id='empty-start-task')

empty_end_task = BashOperator(
task_id='end',
bash_command='echo "Tarefa concluída com sucesso!"'
)

empty_start_task >> empty_end_task

Код: Выделить всё

from datetime import timedelta, datetime
import pendulum
from airflow.models import DAG
from airflow.operators.empty import EmptyOperator
from airflow.sensors.external_task import ExternalTaskSensor

dag_id = 'teste_mediator'

default_args = {
'owner': 'Engineering',
'retries': 2,
'retry_delay': timedelta(minutes=1),
'depends_on_past': False,
'email_on_failure': False,
'email_on_retry': False,
}

with DAG(
dag_id=dag_id,
tags=['teste', 'lakehouse', 'mediator'],
default_args=default_args,
description='teste',
schedule_interval=timedelta(minutes=3),
start_date=datetime(2025, 1, 15,0,0,0),
catchup=False,
) as dag:

waiting = ExternalTaskSensor(
task_id='waiting',
external_dag_id='teste_dagA',
external_task_id='end',
execution_delta=timedelta(minutes=2)
)

empty_end_task = EmptyOperator(task_id='empty-end-task')

waiting >> empty_end_task

Если кто-то понимает проблему, я ценю это.
Я уже внес некоторые изменения с помощью Execution_delta, но безуспешно.Я пытаюсь понять решение моей проблемы

Подробнее здесь: https://stackoverflow.com/questions/793 ... eps-poking