Merge branch 'master' into dependabot/pip/cryptography-41.0.4

Author: mergify[bot]

pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/flows.py

@@ -245,3 +245,11 @@
         stream_logs=True,
         raise_final_state=True,
     )
+
+
+bilhetagem_gps_tratamento.storage = GCS(emd_constants.GCS_FLOWS_BUCKET.value)
+bilhetagem_gps_tratamento.run_config = KubernetesRun(
+    image=emd_constants.DOCKER_IMAGE.value,
+    labels=[emd_constants.RJ_SMTR_AGENT_LABEL.value],
+)
+bilhetagem_gps_tratamento.schedule = every_hour

pipelines/rj_smtr/flows.py

@@ -44,14 +44,15 @@
 
 with Flow(
     "SMTR: Captura",
-    code_owners=["caio", "fernanda", "boris", "rodrigo"],
+    code_owners=["caio", "fernanda", "boris", "rodrigo", "rafaelpinheiro"],
 ) as default_capture_flow:
     # Configuração #
 
     # Parâmetros Gerais #
     table_id = Parameter("table_id", default=None)
     dataset_id = Parameter("dataset_id", default=None)
     partition_date_only = Parameter("partition_date_only", default=None)
+    partition_date_name = Parameter("partition_date_name", default="data")
 
     # Parâmetros Captura #
     extract_params = Parameter("extract_params", default=None)
@@ -61,7 +62,6 @@
     recapture = Parameter("recapture", default=False)
     recapture_window_days = Parameter("recapture_window_days", default=1)
     timestamp = Parameter("timestamp", default=None)
-    partition_date_name = Parameter("partition_date_name", default=None)
 
     # Parâmetros Pré-tratamento #
     primary_key = Parameter("primary_key", default=None)