ativa o schedule do flow de captura do gtfs

prefeitura-rio · Jan 3, 2025 · bb400dc · bb400dc
1 parent 222e3bf
commit bb400dc
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/pipelines/migration/br_rj_riodejaneiro_gtfs/CHANGELOG.md b/pipelines/migration/br_rj_riodejaneiro_gtfs/CHANGELOG.md
@@ -1,5 +1,13 @@
 # Changelog - gtfs
 
+## [1.2.0] - 2025-01-03
+
+### Adicionado
+- Adicionado schedule de 5 minutis do flow de captura do gtfs (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/)
+
+### Removido
+- Removido o teste de quantidade de abas na planilha da Ordem de Serviço (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/)
+
 ## [1.1.9] - 2025-01-02
 
 ### Alterado

diff --git a/pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py b/pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py
@@ -46,7 +46,7 @@
     upload_staging_data_to_gcs,
 )
 
-# from pipelines.schedules import every_5_minutes
+from pipelines.schedules import every_5_minutes
 from pipelines.tasks import (
     check_fail,
     get_scheduled_timestamp,
@@ -293,7 +293,7 @@
     handler_initialize_sentry,
     handler_skip_if_running,
 ]
-# gtfs_captura_nova.schedule = every_5_minutes
+gtfs_captura_nova.schedule = every_5_minutes
 
 
 # with Flow(

diff --git a/pipelines/migration/br_rj_riodejaneiro_gtfs/utils.py b/pipelines/migration/br_rj_riodejaneiro_gtfs/utils.py
@@ -204,9 +204,6 @@ def processa_ordem_servico(
         None
     """
 
-    if len(sheetnames) != 3 and regular_sheet_index is None:
-        raise Exception("More than 3 tabs in the file. Please specify the regular sheet index.")
-
     if regular_sheet_index is None:
         regular_sheet_index = next(
             (i for i, name in enumerate(sheetnames) if "ANEXO I" in name), None