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"