From fbce5ce16bd01ecafa42a090a8ebaf0014096739 Mon Sep 17 00:00:00 2001 From: Catherine Noll Date: Sun, 28 Jan 2024 14:25:12 -0500 Subject: [PATCH] mypy fix --- .../python/airbyte_cdk/sources/streams/concurrent/adapters.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/adapters.py b/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/adapters.py index 4e5f1417ba2b..7f9959f545e4 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/adapters.py +++ b/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/adapters.py @@ -153,7 +153,7 @@ def read_records( yield from self._read_records() except Exception as exc: if hasattr(self._cursor, "state"): - state = self._cursor.state + state = str(self._cursor.state) else: # This shouldn't happen if the ConcurrentCursor was used state = "unknown; no state attribute was available on the cursor"