fixed pbars actors
This commit is contained in:
@@ -50,6 +50,5 @@ done
|
|||||||
##############################################################################################
|
##############################################################################################
|
||||||
|
|
||||||
#### call your code below
|
#### call your code below
|
||||||
export SCGENERATOR_HUSH_PROGRESS=""
|
|
||||||
scgenerator {command} {configs_list}
|
scgenerator {command} {configs_list}
|
||||||
exit
|
exit
|
||||||
@@ -629,8 +629,10 @@ class RaySimulations(Simulations, priority=2):
|
|||||||
self.jobs = []
|
self.jobs = []
|
||||||
self.actors = {}
|
self.actors = {}
|
||||||
self.rolling_id = 0
|
self.rolling_id = 0
|
||||||
self.p_actor = ray.remote(utils.ProgressBarActor).remote(
|
self.p_actor = (
|
||||||
self.sim_jobs_total, self.param_seq.num_steps
|
ray.remote(utils.ProgressBarActor)
|
||||||
|
.options(override_environment_variables=io.get_all_environ())
|
||||||
|
.remote(self.sim_jobs_total, self.param_seq.num_steps)
|
||||||
)
|
)
|
||||||
|
|
||||||
def new_sim(self, variable_list: List[tuple], params: dict):
|
def new_sim(self, variable_list: List[tuple], params: dict):
|
||||||
|
|||||||
@@ -31,7 +31,7 @@ def create_parser():
|
|||||||
parser.add_argument(
|
parser.add_argument(
|
||||||
"--environment-setup",
|
"--environment-setup",
|
||||||
required=False,
|
required=False,
|
||||||
default=f"source {os.path.expanduser('~/anaconda3/etc/profile.d/conda.sh')} && conda activate sc",
|
default=f"source {os.path.expanduser('~/anaconda3/etc/profile.d/conda.sh')} && conda activate sc && export SCGENERATOR_HUSH_PROGRESS=\"\"",
|
||||||
help="commands to run to setup the environement (default : activate the sc environment with conda)",
|
help="commands to run to setup the environement (default : activate the sc environment with conda)",
|
||||||
)
|
)
|
||||||
parser.add_argument(
|
parser.add_argument(
|
||||||
|
|||||||
Reference in New Issue
Block a user