We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7ebfd9 commit ea85761Copy full SHA for ea85761
airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -229,10 +229,10 @@ def ensure_at_least_one_state_emitted(self) -> None:
229
230
def _throttle_state_message(self) -> Optional[float]:
231
"""
232
- Throttles the state message emission to once every 60 seconds.
+ Throttles the state message emission to once every 600 seconds.
233
234
current_time = time.time()
235
- if current_time - self._last_emission_time <= 60:
+ if current_time - self._last_emission_time <= 600:
236
return None
237
return current_time
238
0 commit comments