diff --git a/teste_dag.py b/teste_dag.py index 97d4ca97953dde38abc91a7d3ab32f25ee43c5cc..d0d38155cf6ac36fd3e7637a007cc326b456f8a5 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -47,12 +47,8 @@ repo_home = '/opt/airflow/dags/repo' @dag -def teste( - params={ - "input_file" : Param(type=str) - } -): - print(params.input_file) +def teste(): + print("Hello world") @dag def run_tests(): @@ -63,5 +59,5 @@ def run_tests(): ) -dag2 = teste("parametro") +dag2 = teste() # dag3 = run_tests()