| 22 | self.eta, self.delay = eta, delay |
| 23 | super(RetryTask, self).__init__(msg, *args, **kwargs) |
| 24 | class TaskException(Exception): |
| 25 | def __init__(self, metadata=None, *args): |
| 26 | self.metadata = metadata or {} |
| 27 | super(TaskException, self).__init__(*args) |
| 28 | |
| 29 | def __str__(self): |
| 30 | return self.metadata.get('error') or 'unknown error' |