diff --git a/wetb/hawc2/cluster_simulation.py b/wetb/hawc2/cluster_simulation.py index ea5a78bb716387627b242eae559ea4f6fa385ca8..c67377f58a723b324b91f1cafe3665520770dcd1 100644 --- a/wetb/hawc2/cluster_simulation.py +++ b/wetb/hawc2/cluster_simulation.py @@ -4,15 +4,15 @@ import sys from threading import Thread class ClusterSimulation(Simulation): def __init__(self, modelpath, htcfilename, hawc2exe="HAWC2MB.exe"): - print ("start") Simulation.__init__(self, modelpath, htcfilename, hawc2exe=hawc2exe) + self.simulation_id = [f for f in os.listdir('.') if f.endswith('.in')][0][:-3] - self.resource.simulationThread.low_priority = False + self.host.simulationThread.low_priority = False self.non_blocking_simulation_thread = Thread(target=self.simulate) self.start(1) self.wait() - print (self.resource.simulationThread.res[1]) # print hawc2 output to stdout - sys.exit(self.resource.simulationThread.res[0]) + print (self.host.simulationThread.res[1]) # print hawc2 output to stdout + sys.exit(self.host.simulationThread.res[0]) def update_status(self, *args, **kwargs): Simulation.update_status(self, *args, **kwargs)