Skip to content
Snippets Groups Projects
Commit 8d87f04c authored by edvs19's avatar edvs19
Browse files

teste

parent 0f8dba1c
No related branches found
No related tags found
No related merge requests found
...@@ -23,7 +23,7 @@ with DAG( ...@@ -23,7 +23,7 @@ with DAG(
task_id="landing_to_bronze", task_id="landing_to_bronze",
application=f"{repo_home}/gen_bronze.py", application=f"{repo_home}/gen_bronze.py",
application_args=[ application_args=[
dag1.params.input_file dag1.params["input_file"]
], ],
packages="org.apache.hadoop:hadoop-aws:3.3.4" packages="org.apache.hadoop:hadoop-aws:3.3.4"
) )
...@@ -50,7 +50,7 @@ with DAG( ...@@ -50,7 +50,7 @@ with DAG(
"files": Param([], type="array"), "files": Param([], type="array"),
}, },
) as dag2: ) as dag2:
files = dag2.params.files files = dag2.params["files"]
ops = [] ops = []
for file in files: for file in files:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment