return os.path.join(self.app_home(endpoint), self.ec.run_id)
def endpoint_mkdir(self, endpoint):
- self.endpoint.node.mkdir(self.run_home(self.endpoint))
+ endpoint.node.mkdir(self.run_home(endpoint))
def initiate_connection(self, endpoint, remote_endpoint):
raise NotImplementedError