You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2020/12/03 10:38:51 UTC
[airflow] branch v1-10-stable updated: Add back mistakenly removed
scheduler command (#12779)
This is an automated email from the ASF dual-hosted git repository.
ash pushed a commit to branch v1-10-stable
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v1-10-stable by this push:
new 41edd25 Add back mistakenly removed scheduler command (#12779)
41edd25 is described below
commit 41edd2532a24782aad8fee0a1aac7fc15c512ade
Author: Ash Berlin-Taylor <as...@firemirror.com>
AuthorDate: Thu Dec 3 10:37:20 2020 +0000
Add back mistakenly removed scheduler command (#12779)
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 c22e847..a155cff 100644
--- a/airflow/bin/cli.py
+++ b/airflow/bin/cli.py
@@ -3871,6 +3871,12 @@ class CLIFactory(object):
'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",
'args': ('port', 'workers', 'workerclass', 'worker_timeout', 'hostname',