MCPcopy
hub / github.com/celery/celery / get

Method get

celery/result.py:698–712  ·  view source on GitHub ↗

See :meth:`join`. This is here for API compatibility with :class:`AsyncResult`, in addition it uses :meth:`join_native` if available for the current result backend.

(self, timeout=None, propagate=True, interval=0.5,
            callback=None, no_ack=True, on_message=None,
            disable_sync_subtasks=True, on_interval=None)

Source from the content-addressed store, hash-verified

696 return self.results[index]
697
698 def get(self, timeout=None, propagate=True, interval=0.5,
699 callback=None, no_ack=True, on_message=None,
700 disable_sync_subtasks=True, on_interval=None):
701 """See :meth:`join`.
702
703 This is here for API compatibility with :class:`AsyncResult`,
704 in addition it uses :meth:`join_native` if available for the
705 current result backend.
706 """
707 return (self.join_native if self.supports_native_join else self.join)(
708 timeout=timeout, propagate=propagate,
709 interval=interval, callback=callback, no_ack=no_ack,
710 on_message=on_message, disable_sync_subtasks=disable_sync_subtasks,
711 on_interval=on_interval,
712 )
713
714 def join(self, timeout=None, propagate=True, interval=0.5,
715 callback=None, no_ack=True, on_message=None,

Callers 15

test_result_setMethod · 0.95
test_result_set_errorMethod · 0.95
test_getMethod · 0.95
test_get_emptyMethod · 0.95
joinMethod · 0.95
get_abbrFunction · 0.45
is_using_quorum_queuesFunction · 0.45
rename_widgetFunction · 0.45
joinallFunction · 0.45
unlock_graphFunction · 0.45

Calls

no outgoing calls

Tested by 5

test_result_setMethod · 0.76
test_result_set_errorMethod · 0.76
test_getMethod · 0.76
test_get_emptyMethod · 0.76