Skip to content

Commit 3a587e4

Browse files
authored
Reduce the checkpointing log level (#377)
1 parent cf569eb commit 3a587e4

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

quixstreams/processing_context.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,9 +72,11 @@ def commit_checkpoint(self, force: bool = False):
7272
"""
7373
if not self._checkpoint.empty() and (self._checkpoint.expired() or force):
7474

75-
logger.info(f"Committing a checkpoint force={force}")
75+
logger.debug(f"Committing a checkpoint force={force}")
7676
start = time.monotonic()
7777
self._checkpoint.commit()
7878
elapsed = round(time.monotonic() - start, 2)
79-
logger.info(f"Committed a checkpoint force={force} time_elapsed={elapsed}s")
79+
logger.debug(
80+
f"Committed a checkpoint force={force} time_elapsed={elapsed}s"
81+
)
8082
self.init_checkpoint()

0 commit comments

Comments
 (0)