Merge "Moving task cache update into task creation transaction"

This commit is contained in:
Jenkins 2017-02-07 17:11:22 +00:00 committed by Gerrit Code Review
commit 3d6d48a233
1 changed files with 2 additions and 1 deletions

View File

@ -909,8 +909,9 @@ class DeleteIBPImagesTask(object):
def execute(cls, cluster, image_data):
task = Task(name=consts.TASK_NAMES.remove_images, cluster=cluster)
db().add(task)
message = cls.message(task, image_data)
db().commit()
rpc.cast('naily', cls.message(task, image_data))
rpc.cast('naily', message)
class StopDeploymentTask(object):