def _configure()

in images/airflow/2.9.2/python/mwaa/logging/config.py [0:0]

• 28 lines of code
• 1 McCabe index (conditional complexity)

def _configure():
    _configure_task_logging()
    _configure_dag_processing_logging()
    # We run a standalone DAG Processor but we don't create a special logger for it
    # because Airflow already has a dedicated logger for it, so we just use that when
    # we run the "dag-processor" Airflow command.
    for comp in ["Worker", "Scheduler", "WebServer", "Triggerer"]:
        log_group_arn, log_level, logging_enabled = get_mwaa_logging_env_vars(comp)
        _configure_subprocesses_logging(
            comp,
            log_group_arn=log_group_arn,
            log_stream_name_prefix=comp.lower(),
            log_level="DEBUG",  # Customer Log Level handled at root logger
            logging_enabled=logging_enabled,
        )
        _configure_subprocesses_logging(
            f"{comp}_requirements",
            log_group_arn=log_group_arn,
            log_stream_name_prefix="requirements_install",
            log_level="INFO",  # We always want to publish requirements logs.
            logging_enabled=logging_enabled,
            log_formatter=logging.Formatter('[%(levelname)s] - %(message)s')
        )
        _configure_subprocesses_logging(
            f"{comp}_startup",
            log_group_arn=log_group_arn,
            log_stream_name_prefix="startup_script_execution",
            log_level="INFO",  # We always want to publish startup script logs.
            logging_enabled=logging_enabled,
            log_formatter=logging.Formatter('[%(levelname)s] - %(message)s')
        )