(self, safe=False)
| 672 | self.send_event('task-rejected', requeue=requeue) |
| 673 | |
| 674 | def info(self, safe=False): |
| 675 | return { |
| 676 | 'id': self.id, |
| 677 | 'name': self.name, |
| 678 | 'args': self._args if not safe else self._argsrepr, |
| 679 | 'kwargs': self._kwargs if not safe else self._kwargsrepr, |
| 680 | 'type': self._type, |
| 681 | 'hostname': self._hostname, |
| 682 | 'time_start': self.time_start, |
| 683 | 'acknowledged': self.acknowledged, |
| 684 | 'delivery_info': self.delivery_info, |
| 685 | 'worker_pid': self.worker_pid, |
| 686 | } |
| 687 | |
| 688 | def humaninfo(self): |
| 689 | return '{0.name}[{0.id}]'.format(self) |
no outgoing calls
no test coverage detected