uranusjr commented on code in PR #27758: URL: https://github.com/apache/airflow/pull/27758#discussion_r1072024191
########## airflow/cli/commands/triggerer_command.py: ########## @@ -18,14 +18,36 @@ from __future__ import annotations import signal +from contextlib import contextmanager +from multiprocessing import Process +from typing import Generator import daemon from daemon.pidfile import TimeoutPIDLockFile from airflow import settings +from airflow.configuration import conf from airflow.jobs.triggerer_job import TriggererJob from airflow.utils import cli as cli_utils from airflow.utils.cli import setup_locations, setup_logging, sigint_handler, sigquit_handler +from airflow.utils.serve_logs import serve_logs + + +@contextmanager +def _serve_logs(skip_serve_logs: bool = False) -> Generator[None, None, None]: + """Starts serve_logs sub-process""" + sub_proc = None + if skip_serve_logs is False: + from functools import partial Review Comment: Should be at the top of the file? -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
