Skip to content

Commit

Permalink
Add a warning message to KPO to warn of one second interval logs dupl…
Browse files Browse the repository at this point in the history
…ication
  • Loading branch information
fdemiane committed May 26, 2024
1 parent 7ad6b98 commit de8f857
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/providers/cncf/kubernetes/utils/pod_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -516,7 +516,7 @@ def consume_logs(*, since_time: DateTime | None = None) -> tuple[DateTime | None
# a timeout is a normal thing and we ignore it and resume following logs
if not isinstance(exc, TimeoutError):
self.log.warning(
"Pod %s log read interrupted but container %s still running",
"Pod %s log read interrupted but container %s still running. Logs generated in the last one second might get duplicated.",
pod.metadata.name,
container_name,
)
Expand Down

0 comments on commit de8f857

Please sign in to comment.