diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py index d905a74f774d..045cf366cf2c 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py +++ b/airbyte-cdk/python/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py @@ -54,10 +54,12 @@ def start(self) -> None: self._start = time.perf_counter_ns() def finish(self) -> int: - if self._start: - return ((time.perf_counter_ns() - self._start) / 1e9).__ceil__() - else: - raise RuntimeError("Global substream cursor timer not started") + start_time = self._start + if start_time is None: + raise RuntimeError("Timer not started") + + elapsed_ns = time.perf_counter_ns() - start_time + return -(-elapsed_ns // 1_000_000_000) class GlobalSubstreamCursor(DeclarativeCursor):