fix pipeline cartao pagamento register now

pipelines/utils/crawler_cgu/constants.py

@@ -175,3 +175,4 @@ class constants(Enum):  # pylint: disable=c0103
             "READ": "_TermoAditivo.csv",
         },
     }
+

pipelines/utils/crawler_cgu/flows.py

@@ -317,3 +317,5 @@
                 )
 flow_cgu_licitacao_contrato.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 flow_cgu_licitacao_contrato.run_config = KubernetesRun(image=constants.DOCKER_IMAGE.value)
+
+

pipelines/utils/crawler_cgu/tasks.py

@@ -43,7 +43,7 @@ def partition_data(table_id: str, dataset_id : str) -> str:
         df = read_csv(dataset_id = dataset_id, table_id = table_id)
         log(df.head())
         if dataset_id == "br_cgu_cartao_pagamento":
-            log(" ---------------------------- Partiting data -----------------------")
+            log("---------------------------- Partiting data -----------------------")
             to_partitions(
                 data = df,
                 partition_columns=['ANO_EXTRATO', 'MES_EXTRATO'],

pipelines/utils/crawler_cgu/utils.py

@@ -2,6 +2,7 @@
 """
 General purpose functions for the br_cgu_cartao_pagamento project
 """
+
 import datetime
 from arrow import get
 from dateutil.relativedelta import relativedelta