def publish_to_dead_letter_queue_topic(self, execution):
    LOGGER.info('Publishing execution to dead letter queue topic')
    self.dead_letter_publisher.send(KAFKA_DEAD_LETTER_QUEUE_TOPIC, value=execution)
    LOGGER.info('Published execution to dead letter queue topic')
def publish_to_dead_letter_queue_topic(self, execution):
    LOGGER.info('Publishing execution to dead letter queue topic')
    self.dead_letter_publisher.send(KAFKA_DEAD_LETTER_QUEUE_TOPIC, value=execution)
    LOGGER.info('Published execution to dead letter queue topic')