We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 22afbf6 commit df00054Copy full SHA for df00054
airbyte_cdk/sources/streams/concurrent/cursor.py
@@ -232,9 +232,7 @@ def observe(self, record: Record) -> None:
232
try:
233
cursor_value = self._extract_cursor_value(record)
234
235
- if record.associated_slice is not None and (
236
- most_recent_cursor_value is None or most_recent_cursor_value < cursor_value
237
- ):
+ if most_recent_cursor_value is None or most_recent_cursor_value < cursor_value:
238
self._most_recent_cursor_value_per_partition[record.associated_slice] = cursor_value
239
except ValueError:
240
self._log_for_record_without_cursor_value()
0 commit comments