

def send_notification(message, routing_key, connection, exchange):
    with kombu.pools.producers[connection].acquire(block=True) as producer:
        kombu.common.maybe_declare(exchange, producer.channel)
        producer.publish(exchange, routing_key)

dataset/ETHPy150Open openstack/stacktach/stacktach/message_service.py send_notification/VarMisuse@54/67 `message`->`exchange`