diff --git a/teste_dag.py b/teste_dag.py index a1b9d4545b523608c2526b236720a20f10cd7017..cfb673d5e13ba38993e08e549ef82ab85e7ac20a 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -55,7 +55,9 @@ with DAG( "files": Param([], type="array"), }, ) as dag2: - files = "{{ params.files }}" + files = dag2.params["files"] + + dag2.log.info(f"Input file { files }") ops = [] for file in files: