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

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

src/a/n/antisocial-HEAD/ve/lib/python2.7/site-packages/celery/tests/app/test_routes.py   antisocial(Download)
            'foo',
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
 
    @with_queues(foo=a_queue, bar=b_queue)
        self.assertDictContainsSubset(
            b_queue,
            expand(route.route_for_task(mytask.name)),
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
        route = routes.MapRoute({'a': {'queue': 'x'}})
        with self.assertRaises(QueueNotFound):
            expand(route.route_for_task('a'))
 
 

src/f/i/firefox-flicks-HEAD/vendor-local/lib/python/celery/tests/app/test_routes.py   firefox-flicks(Download)
            'foo',
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
 
    @with_queues(foo=a_queue, bar=b_queue)
        self.assertDictContainsSubset(
            b_queue,
            expand(route.route_for_task(mytask.name)),
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
        route = routes.MapRoute({'a': {'queue': 'x'}})
        with self.assertRaises(QueueNotFound):
            expand(route.route_for_task('a'))
 
 

src/c/e/celery-HEAD/celery/tests/app/test_routes.py   celery(Download)
            'foo',
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
 
    def test_route_for_task(self):
        self.assertDictContainsSubset(
            self.b_queue,
            expand(route.route_for_task(self.mytask.name)),
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
        route = routes.MapRoute({'a': {'queue': 'x'}})
        with self.assertRaises(QueueNotFound):
            expand(route.route_for_task('a'))
 
 

src/c/e/celery-3.1.11/celery/tests/app/test_routes.py   celery(Download)
            'foo',
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
 
    def test_route_for_task(self):
        self.assertDictContainsSubset(
            self.b_queue,
            expand(route.route_for_task(self.mytask.name)),
        )
        self.assertIsNone(route.route_for_task('celery.awesome'))
        route = routes.MapRoute({'a': {'queue': 'x'}})
        with self.assertRaises(QueueNotFound):
            expand(route.route_for_task('a'))