teste

teste_dag.py

@@ -19,12 +19,12 @@ repo_home = '/opt/airflow/dags/repo'
 )
 def process_records():
     @task
-    def task_spark(params: dict):
+    def task_spark():
         return SparkSubmitOperator(
             task_id="landing_to_bronze",
             application=f"{repo_home}/gen_bronze.py",
             application_args=[
-                params["input_file"]
+                "fichas_cadastro_individual_5000.jsonl"
             ],
             packages="org.apache.hadoop:hadoop-aws:3.3.4"
         )