from collections import defaultdict
from core.models import *
from django.db.models import F, Q
+from django.db import connection
#from openstack.manager import OpenStackManager
from openstack.driver import OpenStackDriver
from util.logger import Logger, logging, logger
raise StepNotReady
def sync(self, S, deletion):
+ try:
step = self.step_lookup[S]
start_time=time.time()
except KeyError:
has_deps = False
+ go = False
+
if (has_deps):
for d in deps:
if d==step.__name__:
logger.info(" step %s self-wait skipped" % step.__name__)
+ go = True
continue
cond = self.step_conditions[d]
logger.info(" step %s wait on dep %s" % (step.__name__, d))
cond.wait()
cond.release()
- go = self.step_status[d] == STEP_STATUS_OK
+ go = go or self.step_status[d] == STEP_STATUS_OK
else:
go = True
except KeyError,e:
logger.info('Step %r is a leaf' % step)
pass
+ finally:
+ connection.close()
def run(self):
if not self.driver.enabled: