fixup! fixup! Fix Airflow Tests after #9178

apache · Jun 12, 2020 · fbadc2c · fbadc2c
1 parent ded9069
commit fbadc2c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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)