Get task meta-data for a task by id.
(self, group_id)
| 1115 | return self.decode_result(meta) |
| 1116 | |
| 1117 | def _restore_group(self, group_id): |
| 1118 | """Get task meta-data for a task by id.""" |
| 1119 | meta = self.get(self.get_key_for_group(group_id)) |
| 1120 | # previously this was always pickled, but later this |
| 1121 | # was extended to support other serializers, so the |
| 1122 | # structure is kind of weird. |
| 1123 | if meta: |
| 1124 | meta = self.decode(meta) |
| 1125 | result = meta['result'] |
| 1126 | meta['result'] = result_from_tuple(result, self.app) |
| 1127 | return meta |
| 1128 | |
| 1129 | def _apply_chord_incr(self, header_result_args, body, **kwargs): |
| 1130 | self.ensure_chords_allowed() |
no test coverage detected