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

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

        def _trace_task_ret(name, uuid, args, kwargs, request={}, app=None, **opts):
    return trace_task((app or current_app).tasks[name],
                      uuid, args, kwargs, request, app=app, **opts)
        


src/c/e/celery-HEAD/celery/tests/worker/test_request.py   celery(Download)
 
from celery import states
from celery.app.trace import (
    trace_task,
    _trace_task_ret,
        message = TaskMessage(self.mytask.name, tid, args=[4])
        _, R, _ = _trace_task_ret(
            self.mytask.name, tid, message.headers,
            message.body, message.content_type,
            message.content_encoding, app=self.app,
        message = TaskMessage(self.mytask.name, tid, args=[4])
        _, R, _ = _trace_task_ret(
            self.mytask.name, tid, message.headers,
            message.body, message.content_type,
            message.content_encoding, app=self.app,

src/c/e/celery-3.1.11/celery/tests/worker/test_request.py   celery(Download)
 
from celery import states
from celery.app.trace import (
    trace_task,
    _trace_task_ret,
            app=self.app,
        )
        res = _trace_task_ret(self.mytask.name, uuid(), [4], {}, app=self.app)
        self.assertEqual(res, 4 ** 4)
 
        except AttributeError:
            pass
        res = _trace_task_ret(self.mytask.name, uuid(), [4], {}, app=self.app)
        self.assertEqual(res, 4 ** 4)