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

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

        def filter_status(state, body, message, **kwargs):
    print(MOVING_PROGRESS_FMT.format(state=state, body=body, **kwargs))
        


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,
    def test_filter_status(self):
        with override_stdouts() as (stdout, stderr):
            filter_status(State(), {'id': '1', 'task': 'add'}, Mock())
            self.assertTrue(stdout.getvalue())
 

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,
    def test_filter_status(self):
        with override_stdouts() as (stdout, stderr):
            filter_status(State(), {'id': '1', 'task': 'add'}, Mock())
            self.assertTrue(stdout.getvalue())