diff --git a/pipelines/migration/br_rj_riodejaneiro_rdo/flows.py b/pipelines/migration/br_rj_riodejaneiro_rdo/flows.py
index 92ac916b..624382ab 100644
--- a/pipelines/migration/br_rj_riodejaneiro_rdo/flows.py
+++ b/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,
     )
diff --git a/pipelines/migration/br_rj_riodejaneiro_rdo/tasks.py b/pipelines/migration/br_rj_riodejaneiro_rdo/tasks.py
index 014bee49..ca3aec20 100644
--- a/pipelines/migration/br_rj_riodejaneiro_rdo/tasks.py
+++ b/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 = []