diff --git a/teste_dag.py b/teste_dag.py index adab9b8d052d9a36c42d63c6cfd5c4c637099234..91eb0fb572af43f59764bf4e59a7d5c85e8f60f3 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 + dag1.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 = dag2.params["files"] ops = [] for file in files: