diff --git a/pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py b/pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py
index 66519e53..30f91fe4 100644
--- a/pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py
+++ b/pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py
@@ -189,7 +189,9 @@
         data_versao=data_versao_gtfs_merge
     )
 
-    data_versao_gtfs_is_str = task(lambda: isinstance(data_versao_gtfs_merge, str))()
+    data_versao_gtfs_is_str = task(lambda data_versao: isinstance(data_versao, str))(
+        data_versao_gtfs_merge
+    )
 
     with case(data_versao_gtfs_is_str, False):
         string_data_versao_gtfs = parse_timestamp_to_string(