teste

teste_dag.py

@@ -19,10 +19,9 @@ with DAG(
         "input_file": Param("invalid_file.jsonl", type="string"),
     },
 ) as dag1:
-    
-    dag1.log.info(f"Input file { dag1.params["input_file"] }")
-    
     file = dag1.params["input_file"]
+    
+    dag1.log.info(f"Input file { file }")
 
     task_spark = SparkSubmitOperator(
         task_id="landing_to_bronze",