From 9d64b6fe3f67f5407457c67f0fd3a98e8486f834 Mon Sep 17 00:00:00 2001 From: edvs19 <edvs19@inf.ufpr.br> Date: Thu, 6 Mar 2025 19:22:35 -0300 Subject: [PATCH] teste --- teste_dag.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/teste_dag.py b/teste_dag.py index cfb673d..c73e278 100644 --- a/teste_dag.py +++ b/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", -- GitLab