corrige arquivos com erro

pipelines/janitor/tasks.py

@@ -2,7 +2,6 @@
 # from typing import Dict, List
 import traceback
 from datetime import datetime
-from typing import Dict, List
 
 import requests
 from prefect import task
@@ -11,6 +10,8 @@
 from pipelines.utils.secret import get_secret
 from pipelines.utils.utils import log
 
+# from typing import Dict, List
+
 
 @task
 def query_active_flow_names(prefix="%SMTR%", prefect_client=None, prefect_project="production"):
@@ -54,7 +55,8 @@ def query_not_active_flows(flows, prefect_client=None, prefect_project="producti
     flow_name, last_version = flows
     now = datetime.now().isoformat()
     query = """
-query($flow_name: String, $last_version: Int, $now: timestamptz!, $offset: Int, $project_name:String){
+query(\
+$flow_name: String, $last_version: Int, $now: timestamptz!, $offset: Int, $project_name:String){
     flow(
         where:{
             name: {_eq:$flow_name},

pipelines/migration/br_rj_riodejaneiro_gtfs/utils.py

@@ -157,7 +157,8 @@ def normalizar_horario(horario):
     Normalizes the given time string.
 
     If the time string contains the word "day", it splits the string into days and time.
-    It converts the days, hours, minutes, and seconds into total hours and returns the normalized time string.
+    It converts the days, hours, minutes, and seconds into total hours and returns
+    the normalized time string.
 
     If the time string does not contain the word "day", it returns the time string as is.
 
@@ -192,7 +193,8 @@ def processa_ordem_servico(
         regular_sheet_index (int, optional): The index of the regular sheet. Defaults to 0.
 
     Raises:
-        Exception: If there are more than 2 tabs in the file or if there are missing or duplicated columns in the order of service data.
+        Exception: If there are more than 2 tabs in the file or if there are missing or
+        duplicated columns in the order of service data.
         Exception: If the validation of 'km_test' and 'km_dia_util' fails.
 
     Returns: