File tree Expand file tree Collapse file tree 1 file changed +1
-5
lines changed
src/airflow_dags/dags/india Expand file tree Collapse file tree 1 file changed +1
-5
lines changed Original file line number Diff line number Diff line change 6
6
from airflow .decorators import dag
7
7
from airflow .operators .latest_only import LatestOnlyOperator
8
8
9
- from airflow_dags .plugins .callbacks .slack import (
10
- get_slack_message_callback_no_action_required ,
11
- )
12
9
from airflow_dags .plugins .operators .ecs_run_task_operator import (
13
10
ContainerDefinition ,
14
11
EcsAutoRegisterRunTaskOperator ,
@@ -54,9 +51,8 @@ def ruvnl_consumer_dag() -> None:
54
51
latest_only_op = LatestOnlyOperator (task_id = "latest_only" )
55
52
56
53
consume_ruvnl_op = EcsAutoRegisterRunTaskOperator (
57
- airflow_task_id = "consume-runvl " ,
54
+ airflow_task_id = "consume-ruvnl " ,
58
55
container_def = ruvnl_consumer ,
59
- on_failure_callback = get_slack_message_callback_no_action_required ("in" ),
60
56
max_active_tis_per_dag = 10 ,
61
57
)
62
58
You can’t perform that action at this time.
0 commit comments