diff --git a/teste_dag.py b/teste_dag.py index 9542c24c18e718ad1dce566d11250d6d35d91bd9..809e40f006b1bb3620ffdf7e2a6af51c149be9a9 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -50,6 +50,12 @@ repo_home = '/opt/airflow/dags/repo' def teste(): print("Hello world") + task = EmptyOperator( + task_id="useless" + ) + + task + dag2 = teste() # dag3 = run_tests()