teste

teste_dag.py

@@ -54,7 +54,7 @@ from airflow.models.param import Param
 @dag(
     dag_id="process_records_teste",
     params={
-        "input_file": Param(type="string"),
+        "input_file": Param("fichas_cadastro_individual",type="string"),
     },
 )
 def process_records():