def METHOD_NAME(self, ds, queue, priority=DatasetActionPriority.DEFAULT, **kwargs):
    msg = {'ds_id': ds.id, 'ds_name': ds.name}
    msg.update(kwargs)
    queue.publish(msg, priority)
    self.logger.info(f'New message posted to {queue}: {msg}')