From 05397c2822206710669824efed6b059037ae488f Mon Sep 17 00:00:00 2001 From: Ash Berlin-Taylor Date: Thu, 3 Dec 2020 09:31:21 +0000 Subject: [PATCH] Add back mistakenly removed scheduler command In #12725 I mistakenly _removed_ `airflow scheduler` command. Oops. (This was caught by our K8s tests, but those weren't run on the PR. Separate issue) --- airflow/bin/cli.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/airflow/bin/cli.py b/airflow/bin/cli.py index c22e84771953f..a155cffc02145 100644 --- a/airflow/bin/cli.py +++ b/airflow/bin/cli.py @@ -3870,6 +3870,12 @@ class CLIFactory(object): 'func': serve_logs, 'help': "Serve logs generate by worker", 'args': tuple(), + }, { + 'func': scheduler, + 'help': "Start a scheduler instance", + 'args': ('dag_id_opt', 'subdir', 'run_duration', 'num_runs', + 'do_pickle', 'pid', 'daemon', 'stdout', 'stderr', + 'log_file'), }, { 'func': webserver, 'help': "Start a Airflow webserver instance",