diff --git a/tests/executors/test_dask_executor.py b/tests/executors/test_dask_executor.py index 84a92003bf45b..ab0826b7827c1 100644 --- a/tests/executors/test_dask_executor.py +++ b/tests/executors/test_dask_executor.py @@ -46,12 +46,12 @@ class TestBaseDask(unittest.TestCase): def assert_tasks_on_executor(self, executor): + + success_command = ['airflow', 'tasks', 'run', '--help'] + fail_command = ['airflow', 'tasks', 'run', 'false'] # start the executor executor.start() - success_command = ['true', 'some_parameter'] - fail_command = ['false', 'some_parameter'] - executor.execute_async(key='success', command=success_command) executor.execute_async(key='fail', command=fail_command)