We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 90cb7c2 + 726ac53 commit 34b08efCopy full SHA for 34b08ef
1 file changed
dags/notice_processing_pipeline.py
@@ -21,7 +21,6 @@
21
DAG_NAME = "notice_processing_pipeline"
22
DAG_ID = "notice_processing_pipeline"
23
24
-
25
def branch_selector(result_branch: str, xcom_forward_keys: List[str] = [NOTICE_IDS_KEY]) -> str:
26
start_with_step_name = get_dag_param(key=START_WITH_STEP_NAME_KEY,
27
default_value=NOTICE_NORMALISATION_PIPELINE_TASK_ID)
0 commit comments