From 8a945e90217191aff291272d44cb7d091a3cd020 Mon Sep 17 00:00:00 2001 From: Tim Sawicki Date: Wed, 3 Jul 2024 09:51:44 -0400 Subject: [PATCH] Change str to repr. Change default commit interval to 2, might lower it more --- quixstreams/app.py | 2 +- quixstreams/state/recovery.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/quixstreams/app.py b/quixstreams/app.py index e6ae0cdaf..8f8c1f49f 100644 --- a/quixstreams/app.py +++ b/quixstreams/app.py @@ -97,7 +97,7 @@ def __init__( quix_sdk_token: Optional[str] = None, consumer_group: Optional[str] = None, auto_offset_reset: AutoOffsetReset = "latest", - commit_interval: float = 5.0, + commit_interval: float = 2.0, consumer_extra_config: Optional[dict] = None, producer_extra_config: Optional[dict] = None, state_dir: str = "state", diff --git a/quixstreams/state/recovery.py b/quixstreams/state/recovery.py index eaa6c5e10..750bb2407 100644 --- a/quixstreams/state/recovery.py +++ b/quixstreams/state/recovery.py @@ -46,7 +46,7 @@ def __init__( self._recovery_consume_position: Optional[int] = None self._initial_offset: Optional[int] = None - def __str__(self): + def __repr__(self): return f"{self.changelog_name}[{self.partition_num}]" @property