-
Notifications
You must be signed in to change notification settings - Fork 14.2k
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.
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
Respect LogFormat when using ES logging with Json Format #13310
Conversation
try: | ||
# pylint: disable=protected-access | ||
return self.formatter._style.format(_ESJsonLogFmt(**log_line.to_dict())) | ||
except Exception: # noqa pylint: disable=broad-except |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What is the reason for exception?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
For now, I can only foresee KeyError
here i.e. if log_format has a key that is not present in ES logs:
log_format = [%%(asctime)s] {{%%(filename)s:%%(lineno)d}} %%(levelname)s - %%(message)s |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
But kept a broad-except to avoid any unforeseen exception but it is just a safeguard and keeps the same behavior as now i.e. return log_line.message
56013df
to
fcda9ec
Compare
This was a log standing bug / behaviour where Timestamps, log level, line number etc were not shown when using ElasticSearch Task Handler (Elasticsearch as remote logging) with json_format=True.
fcda9ec
to
5ea5d44
Compare
The PR is likely OK to be merged with just subset of tests for default Python and Database versions without running the full matrix of tests, because it does not modify the core of Airflow. If the committers decide that the full tests matrix is needed, they will add the label 'full tests needed'. Then you should rebase to the latest master or amend the last commit of the PR, and push it with --force-with-lease. |
This was a log standing bug / behaviour where Timestamps, log level, line number etc were not shown when using ElasticSearch Task Handler (Elasticsearch as remote logging) with json_format=True. (cherry-picked from b6bf253) (cherry picked from commit d16baf79bcdfe0b0266d1ac08e07f12285971b82)
This was a log standing bug / behaviour where Timestamps, log level, line number etc were not shown when using ElasticSearch Task Handler (Elasticsearch as remote logging) with json_format=True. (cherry-picked from b6bf253) (cherry picked from commit d16baf79bcdfe0b0266d1ac08e07f12285971b82) (cherry picked from commit 18644b5)
This was a log standing bug / behaviour where Timestamps, log level, line number etc were not shown when using ElasticSearch Task Handler (Elasticsearch as remote logging) with json_format=True. (cherry-picked from b6bf253) (cherry picked from commit d16baf79bcdfe0b0266d1ac08e07f12285971b82)
This was a log standing bug / behaviour where Timestamps, log level, line number etc were not shown when using ElasticSearch Task Handler (Elasticsearch as remote logging) with json_format=True. (cherry-picked from b6bf253)
This was a log standing bug / behaviour where Timestamps, log level, line number etc were not shown when using ElasticSearch Task Handler (Elasticsearch as remote logging) with json_format=True. (cherry-picked from b6bf253)
This was a log standing bug / behaviour where Timestamps, log level,
line number etc were not shown when using ElasticSearch Task Handler
(Elasticsearch as remote logging) with json_format=True.
Before:
After:
^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code change, Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in UPDATING.md.