add stream name to cursor log statements

Author: brianjlai

airbyte_cdk/sources/streams/concurrent/cursor.py

@@ -245,15 +245,17 @@ def close_partition(self, partition: Partition) -> None:
                 AirbyteMessage(
                     type=Type.LOG,
                     log=AirbyteLogMessage(
-                        level=Level.INFO, message=f"Closing partition {partition.to_slice()}"
+                        level=Level.INFO,
+                        message=f"[{self._stream_name}] Closing partition {partition.to_slice()}",
                     ),
                 )
             )
             self._message_repository.emit_message(
                 AirbyteMessage(
                     type=Type.LOG,
                     log=AirbyteLogMessage(
-                        level=Level.INFO, message=f"\tstate before is {self._concurrent_state}"
+                        level=Level.INFO,
+                        message=f"\t[{self._stream_name}] state before is {self._concurrent_state}",
                     ),
                 )
             )
@@ -270,7 +272,7 @@ def close_partition(self, partition: Partition) -> None:
                         type=Type.LOG,
                         log=AirbyteLogMessage(
                             level=Level.INFO,
-                            message=f"\tstate after merged partition is {self._concurrent_state}",
+                            message=f"\t[{self._stream_name}] state after merged partition is {self._concurrent_state}",
                         ),
                     )
                 )