(self, task)
| 288 | logger.exception('Error occurred sending signal "%s"', signal) |
| 289 | |
| 290 | def serialize_task(self, task): |
| 291 | message = self._registry.create_message(task) |
| 292 | return self.serializer.serialize(message) |
| 293 | |
| 294 | def deserialize_task(self, data): |
| 295 | message = self.serializer.deserialize(data) |