Commit 9e4d98db authored by Jérome Perrin's avatar Jérome Perrin

ACO plugin: logs the number of scenarios

parent 06f7ca2c
...@@ -90,10 +90,12 @@ class ACO(plugin.ExecutionPlugin): ...@@ -90,10 +90,12 @@ class ACO(plugin.ExecutionPlugin):
ant['result'] = self.runOneScenario(ant['input'])['result'] ant['result'] = self.runOneScenario(ant['input'])['result']
else: # asynchronous else: # asynchronous
self.logger.info("Registering a job for %s scenarios" % len(scenario_list))
start_register = time.time()
job_id = distributor.requestSimulationRun( job_id = distributor.requestSimulationRun(
[json.dumps(x).encode('zlib').encode('base64') for x in scenario_list]) [json.dumps(x).encode('zlib').encode('base64') for x in scenario_list])
self.logger.info("Job registered as %s (took %0.2fs)" % (job_id, time.time() - start_register ))
self.logger.info("Job registered: %s" % job_id)
while True: while True:
time.sleep(1.) time.sleep(1.)
result_list = distributor.getJobResult(job_id) result_list = distributor.getJobResult(job_id)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment