def __init__(self, experiment_id: str):
    self.path: str = str((management.create_experiment_directory(experiment_id) / 'dispatcher-pipe'))
    self.file = None
    self._socket = socket.socket(socket.AF_UNIX)
    self._socket.bind(self.path)
    self._socket.listen(1)
def __init__(self, experiment_id: str):
    self.path: str = str((management.create_experiment_directory(experiment_id) / 'dispatcher-pipe'))
    self.file = None
    self._socket = socket.socket(socket.AF_UNIX)
    self._socket.bind(self.path)
    self._socket.listen(1)