(self)
| 143 | return headers |
| 144 | |
| 145 | def as_execution_options(self): |
| 146 | limit_hard, limit_soft = self.timelimit or (None, None) |
| 147 | execution_options = { |
| 148 | 'task_id': self.id, |
| 149 | 'root_id': self.root_id, |
| 150 | 'parent_id': self.parent_id, |
| 151 | 'group_id': self.group, |
| 152 | 'group_index': self.group_index, |
| 153 | 'shadow': self.shadow, |
| 154 | 'chord': self.chord, |
| 155 | 'chain': self.chain, |
| 156 | 'link': self.callbacks, |
| 157 | 'link_error': self.errbacks, |
| 158 | 'expires': self.expires, |
| 159 | 'soft_time_limit': limit_soft, |
| 160 | 'time_limit': limit_hard, |
| 161 | 'headers': self._filter_x_death_headers(self.headers), |
| 162 | 'retries': self.retries, |
| 163 | 'reply_to': self.reply_to, |
| 164 | 'replaced_task_nesting': self.replaced_task_nesting, |
| 165 | 'origin': self.origin, |
| 166 | } |
| 167 | if hasattr(self, 'stamps') and hasattr(self, 'stamped_headers'): |
| 168 | if self.stamps is not None and self.stamped_headers is not None: |
| 169 | execution_options['stamped_headers'] = self.stamped_headers |
| 170 | for k, v in self.stamps.items(): |
| 171 | execution_options[k] = v |
| 172 | return execution_options |
| 173 | |
| 174 | @property |
| 175 | def children(self): |
no test coverage detected