Commit c659aa0e authored by Christos Stavrakakis's avatar Christos Stavrakakis
Browse files

cyclades: Fix bug in update_cluster callback

Decorate 'update_cluster' callback with 'handle_message_delivery' to
handle acknowledgement of messages.
parent eb4d70fa
......@@ -270,6 +270,7 @@ def update_build_progress(vm, msg, event_time):
msg['instance'])
@handle_message_delivery
@transaction.commit_on_success()
def update_cluster(msg):
clustername = msg.get("cluster")
......
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