Skip to content

Support explicit bind address for worker log server #60117

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ananich wants to merge 4 commits into
base: main
Choose a base branch
from
+16 −3
Open

Support explicit bind address for worker log server #60117

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
958ce07
Added WORKER_LOG_SERVER_HOST option
Jan 5, 2026
a3fdd80
Fixed uvicorn parameter
Jan 5, 2026
30385fd
Allow explicit host bind for worker log server
Jan 5, 2026
5b69064
Merge branch 'apache:main' into main
ananich Jan 9, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions airflow-core/src/airflow/config_templates/config.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -977,6 +977,14 @@ logging:
type: string
example: "fastapi,sqlalchemy"
default: ""
worker_log_server_host:
description: |
The interface address on which the worker should start the log server.
If not set, it will default to 0.0.0.0 (or [::] for IPv6).
version_added: ~
type: string
example: "127.0.0.1"
default: ~
worker_log_server_port:
description: |
When you start an Airflow worker, Airflow starts a tiny web server
Expand Down
11 changes: 8 additions & 3 deletions airflow-core/src/airflow/utils/serve_logs/core.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
logger = structlog.get_logger(__name__)


def serve_logs(port=None):
def serve_logs(host=None, port=None):
"""Serve logs generated by Worker."""
# setproctitle causes issue on Mac OS: https://github.com/benoitc/gunicorn/issues/3021
os_type = sys.platform
Expand All @@ -41,11 +41,16 @@ def serve_logs(port=None):
setproctitle("airflow serve-logs")

port = port or conf.getint("logging", "WORKER_LOG_SERVER_PORT")
host = conf.get("logging", "WORKER_LOG_SERVER_HOST", fallback=host)
Copy link
Member

@kaxil kaxil Jan 5, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

new config should be added to https://github.com/apache/airflow/blob/main/airflow-core/src/airflow/config_templates/config.yml

Copy link
Author

@ananich ananich Jan 5, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

https://github.com/apache/airflow/blob/main/airflow-core/src/airflow/config_templates/config.yml updated


if socket.has_dualstack_ipv6():
if host:
serve_log_uri = f"http://{host}:{port}"
elif socket.has_dualstack_ipv6():
serve_log_uri = f"http://[::]:{port}"
host = '::'
else:
serve_log_uri = f"http://0.0.0.0:{port}"
host = '0.0.0.0'

logger.info("Starting log server on %s", serve_log_uri)

Expand All @@ -54,7 +59,7 @@ def serve_logs(port=None):

# Use uvicorn directly for ASGI applications
uvicorn.run(
"airflow.utils.serve_logs.log_server:get_app", host="", port=port, log_level=uvicorn_log_level
"airflow.utils.serve_logs.log_server:get_app", host=host, port=port, log_level=uvicorn_log_level
)
# Log serving is I/O bound and has low concurrency, so single process is sufficient

Expand Down