Fixed issue with sessions.

This commit is contained in:
Timur Nurlygayanov 2013-04-01 15:46:57 +04:00
parent 2cafd9bb0a
commit cd3a5577af
2 changed files with 15 additions and 18 deletions

View File

@ -70,7 +70,18 @@ def datacenters_deploy(request, datacenter_id):
def services_create(request, datacenter, parameters):
session_id = windcclient(request).sessions.list(datacenter)[0].id
session_id = None
sessions = windcclient(request).sessions.list(environment_id)
for s in sessions:
if s.state == 'open':
session_id = s.id
else:
windcclient(request).sessions.delete(environment_id, s.id)
if session_id is None:
session_id = windcclient(request).sessions.configure(environment_id).id
if parameters['service_type'] == 'Active Directory':
service = windcclient(request)\
.activeDirectories\
@ -91,10 +102,7 @@ def services_list(request, datacenter_id):
session_id = None
sessions = windcclient(request).sessions.list(datacenter_id)
for s in sessions:
if s.state in ['open', 'deploying']:
session_id = s.id
else:
windcclient(request).sessions.delete(datacenter_id, s.id)
session_id = s.id
if session_id is None:
session_id = windcclient(request).sessions.configure(datacenter_id).id
@ -120,10 +128,7 @@ def get_active_directories(request, datacenter_id):
sessions = windcclient(request).sessions.list(datacenter_id)
for s in sessions:
if s.state in ['open', 'deploying']:
session_id = s.id
else:
windcclient(request).sessions.delete(datacenter_id, s.id)
session_id = s.id
if session_id is None:
session_id = windcclient(request).sessions.configure(datacenter_id).id
@ -172,10 +177,7 @@ def get_status_message_for_service(request, service_id):
sessions = windcclient(request).sessions.list(environment_id)
for s in sessions:
if s.state in ['open', 'deploying']:
session_id = s.id
else:
windcclient(request).sessions.delete(environment_id, s.id)
session_id = s.id
if session_id is None:
session_id = windcclient(request).sessions.configure(environment_id).id

View File

@ -132,11 +132,6 @@ class UpdateServiceRow(tables.Row):
datacenter_id = re.search('windc/(\S+)', link).group(0)[6:-1]
service = api.services_get(request, datacenter_id, service_id)
#if service:
# service['operation'] = api. \
# get_status_message_for_service(request, service_id)
LOG.critical(service)
return service