sdalmia11

``` def _notification_callback(self, _, pid, channel, payload): LOG.info("_notification_callback invoked", channel=channel, pid=pid, payload_preview=str(payload)[:100]) print(f"Notification callback invoked for channel: {channel}, pid: {pid}, payload: {payload}") # Create a task to process this notification...