Merge "Moving task cache update into task creation transaction"
This commit is contained in:
commit
3d6d48a233
|
@ -909,8 +909,9 @@ class DeleteIBPImagesTask(object):
|
||||||
def execute(cls, cluster, image_data):
|
def execute(cls, cluster, image_data):
|
||||||
task = Task(name=consts.TASK_NAMES.remove_images, cluster=cluster)
|
task = Task(name=consts.TASK_NAMES.remove_images, cluster=cluster)
|
||||||
db().add(task)
|
db().add(task)
|
||||||
|
message = cls.message(task, image_data)
|
||||||
db().commit()
|
db().commit()
|
||||||
rpc.cast('naily', cls.message(task, image_data))
|
rpc.cast('naily', message)
|
||||||
|
|
||||||
|
|
||||||
class StopDeploymentTask(object):
|
class StopDeploymentTask(object):
|
||||||
|
|
Loading…
Reference in New Issue