Skip to content

Commit 53a5a0e

Browse files
committed
improve log message
1 parent c7c5a95 commit 53a5a0e

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -526,7 +526,11 @@ def observe(self, record: Record) -> None:
526526
except ValueError as exception:
527527
if not self._logged_regarding_datetime_format_error:
528528
logger.warning(
529-
f"Tried to parse cursor value `{record_cursor_value}` but go error: {exception}"
529+
"Skipping cursor update for stream '%s': failed to parse cursor field '%s' value %r: %s",
530+
self._stream_name,
531+
self._cursor_field.cursor_field_key,
532+
record_cursor_value,
533+
exception,
530534
)
531535
self._logged_regarding_datetime_format_error = True
532536
return

0 commit comments

Comments
 (0)