Method run

lada/utils/threading_utils.py:37–42

(self)

        self.name = name

    def run(self):
        try:
            super().run()
        except Exception as e:
            logger.error(f"{self.name}: Crashed", exc_info=True)
            self.error_handler(ErrorMarker(message=str(e), stack_trace=traceback.format_exc()))

class PipelineQueue(Queue):
    def __init__(self, name: str, maxsize=0):