diff --git a/wetb/hawc2/simulation_resources.py b/wetb/hawc2/simulation_resources.py index b9650f8db3bf1e517565dbdb18fe9c9cd91dd4be..85b4a497094f9c2f18b177452a5560878293ef6e 100644 --- a/wetb/hawc2/simulation_resources.py +++ b/wetb/hawc2/simulation_resources.py @@ -261,8 +261,9 @@ class PBSClusterSimulationHost(SimulationHost): hawc2exe = property(lambda self : os.path.basename(self.sim.hawc2exe)) - def glob(self, *args,**kwargs): - return self.ssh.glob(*args,**kwargs) + def glob(self, filepattern, cwd="", recursive=False): + return self.ssh.glob(filepattern, cwd, recursive) + def get_datetime(self): v, out, err = self.ssh.execute('date "+%Y,%m,%d,%H,%M,%S"') if v == 0: diff --git a/wetb/utils/cluster_tools/cluster_resource.py b/wetb/utils/cluster_tools/cluster_resource.py index 55206763141b49d1ce2d99cca0953728b8cf6c98..5c128cc59a8f84fafdd630cb3d31f0c1b17acfdc 100644 --- a/wetb/utils/cluster_tools/cluster_resource.py +++ b/wetb/utils/cluster_tools/cluster_resource.py @@ -112,6 +112,9 @@ class SSHPBSClusterResource(Resource): Resource.__init__(self, min_cpu, min_free) self.ssh = sshclient self.resource_lock = threading.Lock() + + def glob(self, filepattern, cwd="", recursive=False): + return self.ssh.glob(filepattern, cwd, recursive) @property def host(self):