Skip to content
Merged
Show file tree
Hide file tree
Changes from 7 commits
Commits
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
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@
- Use `--console-log-format` (or `CONSOLE_LOG_FORMAT`) to set the format to `plain` (default) or `json`.
- Add support for airflow `2.10.5` ([#625]).
- Add experimental support for airflow `3.0.1` ([#630]).
- "airflow.task" logger defaults to log level 'INFO' instead of 'NOTSET' ([#649]).

### Changed

Expand Down Expand Up @@ -50,6 +51,7 @@
[#630]: https://github.com/stackabletech/airflow-operator/pull/630
[#636]: https://github.com/stackabletech/airflow-operator/pull/636
[#645]: https://github.com/stackabletech/airflow-operator/pull/645
[#649]: https://github.com/stackabletech/airflow-operator/pull/649

## [25.3.0] - 2025-03-21

Expand Down
4 changes: 4 additions & 0 deletions docs/modules/airflow/pages/usage-guide/logging.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,8 @@

The logs can be forwarded to a Vector log aggregator by providing a discovery ConfigMap for the aggregator and by enabling the log agent:

NOTE: airflow.task log level is set to `INFO` by default.
Comment thread
Maleware marked this conversation as resolved.
Outdated

[source,yaml]
----
spec:
Expand All @@ -26,6 +28,8 @@ spec:
loggers:
"airflow.processor":
level: INFO
"airflow.task":
level: DEBUG
schedulers:
config:
logging:
Expand Down
5 changes: 5 additions & 0 deletions rust/operator-binary/src/product_logging.rs
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,11 @@ for logger_name, logger_config in LOGGING_CONFIG['loggers'].items():
# otherwise DAGs cannot be loaded anymore.
if logger_name != 'airflow.task':
logger_config['propagate'] = True
# The default behavior of airflow is to enforce log level 'INFO' on tasks. (https://airflow.apache.org/docs/apache-airflow/stable/configurations-ref.html#logging-level)
# TODO: Make task handler log level configurable through CRDs with default 'INFO'.
# e.g. LOGGING_CONFIG['handlers']['task']['level'] = {{task_log_level}}
if 'task' in logger_config['handlers']:
Comment thread
siegfriedweber marked this conversation as resolved.
Outdated
logger_config['level'] = logging.INFO

LOGGING_CONFIG.setdefault('formatters', {{}})
LOGGING_CONFIG['formatters']['json'] = {{
Expand Down