Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(2)  |  Call(0)  |  Derive(0)  |  Import(2)

        def expand_dest(ret, exchange, routing_key):
    try:
        ex, rk = ret
    except (TypeError, ValueError):
        ex, rk = exchange, routing_key
    return ex, rk
        


src/c/e/celery-3.1.11/celery/tests/contrib/test_migrate.py   celery(Download)
from kombu.transport.virtual import QoS
 
from celery.contrib.migrate import (
    StopFiltering,
    State,

src/c/e/celery-HEAD/celery/tests/contrib/test_migrate.py   celery(Download)
from kombu.transport.virtual import QoS
 
from celery.contrib.migrate import (
    StopFiltering,
    State,