diff --git a/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/covid19_genome_sequence_dag.py b/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/covid19_genome_sequence_dag.py index e7e920885..d25963db2 100644 --- a/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/covid19_genome_sequence_dag.py +++ b/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/covid19_genome_sequence_dag.py @@ -43,7 +43,7 @@ env_vars={ "SOURCE_PROJECT_ID": "{{ var.json.covid19_genome_sequence.source_project_id }}", "SOURCE_BQ_DATASET": "{{ var.json.covid19_genome_sequence.source_bq_dataset }}", - "TARGET_PROJECT_ID": "{{ var.json.covid19_genome_sequence.target_project_id }}", + "TARGET_PROJECT_ID": "{{ var.value.gcp_project }}", "TARGET_BQ_DATASET": "{{ var.json.covid19_genome_sequence.target_bq_dataset }}", }, resources={"request_memory": "128M", "request_cpu": "200m"}, diff --git a/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/pipeline.yaml b/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/pipeline.yaml index c5945560a..14a6e2698 100644 --- a/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/pipeline.yaml +++ b/datasets/covid19_genome_sequence/pipelines/covid19_genome_sequence/pipeline.yaml @@ -41,7 +41,7 @@ dag: env_vars: SOURCE_PROJECT_ID: "{{ var.json.covid19_genome_sequence.source_project_id }}" SOURCE_BQ_DATASET: "{{ var.json.covid19_genome_sequence.source_bq_dataset }}" - TARGET_PROJECT_ID: "{{ var.json.covid19_genome_sequence.target_project_id }}" + TARGET_PROJECT_ID: "{{ var.value.gcp_project }}" TARGET_BQ_DATASET: "{{ var.json.covid19_genome_sequence.target_bq_dataset }}" resources: request_memory: "128M"