Commit 74489c4a authored by Daniele Venzano's avatar Daniele Venzano

Fix pylint errors

parent 7ab7368b
...@@ -89,15 +89,15 @@ class APIEndpoint: ...@@ -89,15 +89,15 @@ class APIEndpoint:
reserved_cores = 0 reserved_cores = 0
reserved_mem = 0 reserved_mem = 0
for e in running_execs: for e in running_execs:
for s in e.services: for service in e.services:
reserved_cores += s.resource_reservation.cores.min reserved_cores += service.resource_reservation.cores.min
reserved_mem += s.resource_reservation.memory.min reserved_mem += service.resource_reservation.memory.min
new_exec_cores = 0 new_exec_cores = 0
new_exec_memory = 0 new_exec_memory = 0
for s in application_description['services']: for service in application_description['services']:
new_exec_cores += s['resources']['cores']['min'] * s['total_count'] new_exec_cores += service['resources']['cores']['min'] * service['total_count']
new_exec_memory += s['resources']['memory']['min'] * s['total_count'] new_exec_memory += service['resources']['memory']['min'] * service['total_count']
if quota.cores < reserved_cores + new_exec_cores: if quota.cores < reserved_cores + new_exec_cores:
raise zoe_api.exceptions.ZoeQuotaException('You requested {} cores more than your quota allows, quota exceeded.'.format((reserved_cores + new_exec_cores) - quota.cores)) raise zoe_api.exceptions.ZoeQuotaException('You requested {} cores more than your quota allows, quota exceeded.'.format((reserved_cores + new_exec_cores) - quota.cores))
...@@ -420,4 +420,3 @@ class APIEndpoint: ...@@ -420,4 +420,3 @@ class APIEndpoint:
if e.time_submit + runtime_limit > datetime.utcnow(): if e.time_submit + runtime_limit > datetime.utcnow():
log.info('Automatically terminating execution {} that has exceeded the run time limit'.format(e.id)) log.info('Automatically terminating execution {} that has exceeded the run time limit'.format(e.id))
self.execution_terminate(e.owner, e.id) self.execution_terminate(e.owner, e.id)
...@@ -75,8 +75,8 @@ def zoe_web_main(test_conf=None) -> int: ...@@ -75,8 +75,8 @@ def zoe_web_main(test_conf=None) -> int:
http_server.bind(args.listen_port, args.listen_address) http_server.bind(args.listen_port, args.listen_address)
http_server.start(num_processes=1) http_server.start(num_processes=1)
pc = PeriodicCallback(api_endpoint.verify_runtime_limit, 300000) runtime_limit_cb = PeriodicCallback(api_endpoint.verify_runtime_limit, 300000)
pc.start() runtime_limit_cb.start()
try: try:
IOLoop.current().start() IOLoop.current().start()
......
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