Deploying to gh-pages from @ 482ed55 🚀

prefeitura-rio · Feb 22, 2024 · 0a97d13 · 0a97d13
1 parent 17a23ea
commit 0a97d13
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/rj_smtr/br_rj_riodejaneiro_gtfs/flows.html b/rj_smtr/br_rj_riodejaneiro_gtfs/flows.html
@@ -144,6 +144,13 @@ <h1 class="title">Module <code>pipelines.rj_smtr.br_rj_riodejaneiro_gtfs.flows</
                 &#34;version&#34;: {},
             },
         }
+        gtfs_materializacao_parameters_new = {
+            &#34;dataset_id&#34;: &#34;gtfs&#34;,
+            &#34;dbt_vars&#34;: {
+                &#34;data_versao_gtfs&#34;: data_versao_gtfs,
+                &#34;version&#34;: {},
+            },
+        }
 
         run_materializacao = create_flow_run(
             flow_name=gtfs_materializacao.name,
@@ -153,13 +160,28 @@ <h1 class="title">Module <code>pipelines.rj_smtr.br_rj_riodejaneiro_gtfs.flows</
             upstream_tasks=[wait_captura],
         )
 
+        run_materializacao_new_dataset_id = create_flow_run(
+            flow_name=gtfs_materializacao.name,
+            project_name=emd_constants.PREFECT_DEFAULT_PROJECT.value,
+            parameters=gtfs_materializacao_parameters_new,
+            labels=LABELS,
+            upstream_tasks=[wait_captura],
+        )
+
         wait_materializacao = wait_for_flow_run(
             run_materializacao,
             stream_states=True,
             stream_logs=True,
             raise_final_state=True,
         )
 
+        wait_materializacao_new_dataset_id = wait_for_flow_run(
+            run_materializacao_new_dataset_id,
+            stream_states=True,
+            stream_logs=True,
+            raise_final_state=True,
+        )
+
 gtfs_captura_tratamento.storage = GCS(emd_constants.GCS_FLOWS_BUCKET.value)
 gtfs_captura_tratamento.run_config = KubernetesRun(
     image=emd_constants.DOCKER_IMAGE.value,