Skip to content

Commit f6bfa33

Browse files
Update worker_single_notice_process_orchestrator.py
1 parent e828be1 commit f6bfa33

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

dags/worker_single_notice_process_orchestrator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from airflow.operators.python import get_current_context, BranchPythonOperator, PythonOperator
22
from airflow.utils.trigger_rule import TriggerRule
33
from pymongo import MongoClient
4-
4+
from airflow.decorators import dag
55
from dags import DEFAULT_DAG_ARGUMENTS
66
from dags.dags_utils import pull_dag_upstream, push_dag_downstream
77
from ted_sws import config

0 commit comments

Comments
 (0)