Searched refs:get_task_meta (Results 1 – 10 of 10) sorted by relevance
141 assert b.get_task_meta(uuid())['status'] == states.PENDING201 backend.get_task_meta('id')214 r1 = backend.get_task_meta(tid)222 backend.get_task_meta(tid)232 assert backend.get_task_meta(tid) == 'hello'293 meta = b.get_task_meta(tid)
108 meta = tb.get_task_meta('xxx-does-not-exist-at-all')259 meta = tb.get_task_meta(tid)288 meta = tb.get_task_meta(tid)
992 b.get_task_meta(sentinel.task_id)1012 res = b.get_task_meta(sentinel.task_id)1032 b.get_task_meta(sentinel.task_id)1053 b.get_task_meta(sentinel.task_id)
472 return self.get_task_meta(task_id)['status']478 return self.get_task_meta(task_id).get('traceback')482 return self.get_task_meta(task_id).get('result')487 return self.get_task_meta(task_id)['children']508 def get_task_meta(self, task_id, cache=True): member in Backend549 self._cache[task_id] = self.get_task_meta(task_id, cache=False)687 meta = self.get_task_meta(task_id)
236 def get_task_meta(self, task_id, backlog_limit=1000): member in RPCBackend267 poll = get_task_meta # XXX compat
161 def get_task_meta(self, task_id, backlog_limit=1000): member in AMQPBackend196 poll = get_task_meta # XXX compat
939 meta = self.mytask.backend.get_task_meta(tid)976 meta = mytask_no_kwargs.backend.get_task_meta(tid)989 meta = self.mytask.backend.get_task_meta(tid)1004 meta = self.mytask_raising.backend.get_task_meta(tid)
423 return self._maybe_set_cache(self.backend.get_task_meta(self.id))
151 x.backend.get_task_meta.return_value = {}
606 ``backend.get_task_meta`` in a :keyword:`finally` call leading to