def _get_producer(self, event_type, delay=0):
        try:
            return self._producers[event_type, delay]
        except __HOLE__:
            if delay:
                producer = EventProducerWithDelay(
                    delay=int(1000 * delay),
                    exchange=self.waiting_exchange,
                    routing_key=event_type,
                    event_system=self,
                )
            else:
                producer = EventProducer(
                    exchange=self.exchange,
                    routing_key=event_type,
                    event_system=self,
                )
        self._producers[event_type, delay] = producer
        return producer
dataset/ETHPy150Open deliveryhero/lymph/lymph/events/kombu.py/KombuEventSystem._get_producer