[HOTFIX] Ativar captura do RHO e RDO STPL (#259)

* ativar stpl

* materializacao stpl

* altera ambiente para hmg

* add schema rdo_registros_stpl

* altera logica table_id

* corrige schema

* remove packages

* adiciona trim

* add changelog

* restaura packages

* add dbt deps to dockerfile

* add cd queries to dockerfile

* adiciona exclude

* add workdir in place of cd

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* corrige table_id set_last_run_timestamp

* add flow set redis

* corrige flow redis

* remove flow temporario

* altera target para prod

* fix rdo rho stpl

* teste

* remove size

---------

Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
Co-authored-by: hellcassius <[email protected]>
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>

pipelines/migration/br_rj_riodejaneiro_rdo/flows.py

@@ -129,7 +129,7 @@
     materialize = Parameter("materialize", False)
 
     rename_run = rename_current_flow_run_now_time(
-        prefix=f"{captura_sppo_rho.name} FTP - {transport_mode.run()}-{report_type.run()} ",
+        prefix="RHO - Captura FTP - " + transport_mode + "-" + report_type + " ",
         now_time=get_current_timestamp(),
         wait=None,
     )
@@ -176,7 +176,7 @@
     materialize = Parameter("materialize", False)
 
     rename_run = rename_current_flow_run_now_time(
-        prefix=f"{captura_sppo_rdo.name} FTP - {transport_mode.run()}-{report_type.run()} ",
+        prefix="RHO - Captura FTP - " + transport_mode + "-" + report_type + " ",
         now_time=get_current_timestamp(),
         wait=None,
     )

pipelines/migration/br_rj_riodejaneiro_rdo/tasks.py

@@ -43,7 +43,6 @@ def get_file_paths_from_ftp(
     files_updated_times = {
         file: datetime.timestamp(parser.parse(info["modify"]))
         for file, info in ftp_client.mlsd(transport_mode)
-        if info["size"] != "0"
     }
     # Get files modified inside interval
     files = []