(self, binary)
| 56 | return error_sentinel |
| 57 | |
| 58 | def unpickle(self, binary): |
| 59 | try: |
| 60 | return pickle.loads(binary) |
| 61 | except Exception as e: |
| 62 | self.log.error(f"Error deserializing binary: {e}") |
| 63 | self.log.trace(f"Offending binary: {binary}") |
| 64 | self.log.trace(traceback.format_exc()) |
| 65 | return error_sentinel |
| 66 | |
| 67 | async def _infinite_retry(self, callback, *args, **kwargs): |
| 68 | interval = kwargs.pop("_interval", 300) |
no test coverage detected