Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
time, metrics = run_config(args, db_wrapper, job_config)
if time is not None:
price_per_hour = cluster_config.price(no_master=True)
price_per_video = (time / 3600.0) * price_per_hour / float(sample_size)
return price_per_video, metrics
else:
return None
results = []
for (cluster_config, job_configs) in configs:
# Only bring up the cluster if there exists a job config that hasn't been computed
if not force and all([pcache.has(run_name(cluster_config, job_config)) for job_config in job_configs]):
results.append([pcache.get(run_name(cluster_config, job_config)) for job_config in job_configs])
else:
with make_cluster(cluster_config, no_delete=no_delete) as db_wrapper:
log.info('Cluster config: {}'.format(cluster_config))
def try_config(job_config):
log.info('Job config: {}'.format(job_config))
try:
return test_config(
args, db_wrapper, cluster_config, job_config)
except TestFailure as e:
print(e)
return (str(e), None)
except Exception as e:
traceback.print_exc()
return (traceback.format_exc(), None)