diff --git a/teste_dag.py b/teste_dag.py index 341fd7ca6efa45cbd95fd84c0c910e981153ad83..6a50745962214eebe2f3b16e032f186a8ecb9df5 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -23,7 +23,7 @@ with DAG( task_id="landing_to_bronze", application=f"{repo_home}/gen_bronze.py", application_args=[ - dag1.params["input_file"] + "{{ params.input_file }}" ], packages="org.apache.hadoop:hadoop-aws:3.3.4" ) @@ -50,7 +50,7 @@ with DAG( "files": Param([], type="array"), }, ) as dag2: - files = dag2.params["files"] + files = "{{ params.files }}" ops = [] for file in files: