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',