Method
get
(self, timeout=None, propagate=True,
disable_sync_subtasks=True, **kwargs)
Source from the content-addressed store, hash-verified
| 1017 | return True |
| 1018 | |
| 1019 | def get(self, timeout=None, propagate=True, |
| 1020 | disable_sync_subtasks=True, **kwargs): |
| 1021 | if disable_sync_subtasks: |
| 1022 | assert_will_not_block() |
| 1023 | |
| 1024 | if self.successful(): |
| 1025 | return self.result |
| 1026 | elif self.state in states.PROPAGATE_STATES: |
| 1027 | if propagate: |
| 1028 | raise self.result if isinstance( |
| 1029 | self.result, Exception) else Exception(self.result) |
| 1030 | return self.result |
| 1031 | wait = get # XXX Compat (remove 5.0) |
| 1032 | |
| 1033 | def forget(self): |