ashb commented on a change in pull request #15070:
URL: https://github.com/apache/airflow/pull/15070#discussion_r604073416
##########
File path: airflow/cli/commands/scheduler_command.py
##########
@@ -17,20 +17,27 @@
"""Scheduler command"""
import signal
+from multiprocessing import Process
+from typing import Optional
import daemon
from daemon.pidfile import TimeoutPIDLockFile
from airflow import settings
+from airflow.configuration import conf
from airflow.jobs.scheduler_job import SchedulerJob
from airflow.utils import cli as cli_utils
from airflow.utils.cli import process_subdir, setup_locations, setup_logging,
sigint_handler, sigquit_handler
+from airflow.utils.serve_logs import serve_logs
@cli_utils.action_logging
def scheduler(args):
"""Starts Airflow Scheduler"""
print(settings.HEADER)
+ skip_serve_logs = args.skip_serve_logs
Review comment:
This won't currently be set for scheduler sub-command -- you'll need to
add it somewhere in the cli parser.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
