Skip to content

Commit b0d92f0

Browse files
author
ia-tests
committed
refactor running dags
1 parent 61d8897 commit b0d92f0

File tree

5 files changed

+7
-6
lines changed

5 files changed

+7
-6
lines changed

cd/prod.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ steps:
139139
'deploy-wordcount-jar'
140140
]
141141
args: [
142-
'-dagList=./config/ci_dags.txt',
142+
'-dagList=./config/running_dags.txt',
143143
'-dagsFolder=./dags',
144144
'-project=${PROJECT_ID}',
145145
'-region=${_COMPOSER_REGION}',

cloudbuild.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -201,7 +201,7 @@ steps:
201201
'clean-up-data-dir-dags',
202202
]
203203
args: [
204-
'-dagList=./config/ci_dags.txt',
204+
'-dagList=./config/running_dags.txt',
205205
'-dagsFolder=./dags',
206206
'-project=${PROJECT_ID}',
207207
'-region=${_COMPOSER_REGION}',

composer/config/ci_dags.txt

Lines changed: 0 additions & 2 deletions
This file was deleted.

composer/config/running_dags.txt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
wordcount_dag
2+
tutorial
3+
ephemeral_dataproc_spark_dag

composer/tests/test_dag_validation.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,12 +30,12 @@ def setUp(self):
3030
self.dagbag = DagBag(
3131
dag_folder=os.environ.get('AIRFLOW_HOME', "~/airflow/") + '/dags/',
3232
include_examples=False)
33-
with open('./config/ci_dags.txt') as running_dags_txt:
33+
with open('./config/running_dags.txt') as running_dags_txt:
3434
self.running_dag_ids = running_dags_txt.read().splitlines()
3535

3636
def test_no_ignore_running_dags(self):
3737
"""
38-
Tests that we don't have any dags in ci_dags.txt that are
38+
Tests that we don't have any dags in running_dags.txt that are
3939
ignored by .airflowignore
4040
"""
4141
for dag_id in self.running_dag_ids:

0 commit comments

Comments
 (0)