add type of queueu item to log message

Author: maxime.c

airbyte_cdk/sources/concurrent_source/concurrent_source.py

@@ -146,7 +146,7 @@ def _consume_from_queue(
         while airbyte_message_or_record_or_exception := queue.get():
             test_env = os.getenv("PYTEST_CURRENT_TEST")
             if test_env and "test_concurrent_declarative_source.py" in test_env:
-                self._logger.info(f"Processing and emitting: {airbyte_message_or_record_or_exception.__dict__}")
+                self._logger.info(f"Processing and emitting {type(airbyte_message_or_record_or_exception)}: {airbyte_message_or_record_or_exception.__dict__}")
             yield from self._handle_item(
                 airbyte_message_or_record_or_exception,
                 concurrent_stream_processor,