Skip to content

Commit 9ebebed

Browse files
committed
extra logging for CI debug
1 parent 2632aac commit 9ebebed

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

dev_utils/dev_utils/service_helper_sync.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,19 @@ def on_event_batch(partition_context, events):
258258
for event in events:
259259
device_id = get_device_id_from_event(event)
260260
module_id = get_module_id_from_event(event)
261+
message_source = get_message_source_from_event(event)
262+
263+
# TODO: Remove this verbose logging after debugging twin change event issue
264+
# Log all incoming events with their message source for debugging
265+
logger.info(
266+
"EventHub event received: device_id={}, module_id={}, message_source={}, "
267+
"annotations={}".format(
268+
device_id,
269+
module_id,
270+
message_source,
271+
event.message.annotations if event.message else "N/A",
272+
)
273+
)
261274

262275
if device_id == self.device_id and module_id == self.module_id:
263276

0 commit comments

Comments
 (0)