fixed wrong name bug in deployer

docs/apidocs/json_OwnedObject.html

@@ -69,7 +69,7 @@ class</p>
 
       <dl class="dl-horizontal">
         <dt>Subtypes</dt>
-        <dd><a href="json_DeployRequest.html">DeployRequest</a>, <a href="json_KeyPair.html">KeyPair</a>, <a href="json_ProvisionRequest.html">ProvisionRequest</a>, <a href="json_KeyValueHolder.html">KeyValueHolder</a>, <a href="json_PlanResponse.html">PlanResponse</a>, <a href="json_PlaybookRepresentation.html">PlaybookRepresentation</a>, <a href="json_ProvisionResponse.html">ProvisionResponse</a>, <a href="json_Script.html">Script</a>, <a href="json_DeployResponse.html">DeployResponse</a>, <a href="json_ToscaRepresentation.html">ToscaRepresentation</a>, <a href="json_CloudCredentials.html">CloudCredentials</a></dd>
+        <dd><a href="json_DeployRequest.html">DeployRequest</a>, <a href="json_ProvisionRequest.html">ProvisionRequest</a>, <a href="json_KeyPair.html">KeyPair</a>, <a href="json_KeyValueHolder.html">KeyValueHolder</a>, <a href="json_PlanResponse.html">PlanResponse</a>, <a href="json_PlaybookRepresentation.html">PlaybookRepresentation</a>, <a href="json_ProvisionResponse.html">ProvisionResponse</a>, <a href="json_Script.html">Script</a>, <a href="json_DeployResponse.html">DeployResponse</a>, <a href="json_ToscaRepresentation.html">ToscaRepresentation</a>, <a href="json_CloudCredentials.html">CloudCredentials</a></dd>
       </dl>
 
       <table class="table datatype-properties">

drip-deployer/playbook.retry

-172.17.0.2

drip-deployer/rpc_server.py

@@ -27,7 +27,6 @@ channel.queue_declare(queue='deployer_queue')
 
 
 
-manager_type = ""
 done = False
 
 def threaded_function(args):
@@ -89,14 +88,28 @@ def handleDelivery(message):
 
 def on_request(ch, method, props, body):
     ret = handleDelivery(body)
+    
+    parsed_json = json.loads(body)
+    params = parsed_json["parameters"]
+    
+    for param in params:
+        name = param["name"]
+        if name == "cluster":
+            manager_type = param["value"]
+            break
+    
+            
     if "ERROR" in ret:
         res_name = "error"
     elif manager_type == "ansible":
         res_name = "ansible_output"
     else:
         res_name = "credential"
-
-
+        
+        
+    print manager_type
+    print res_name
+    
     response = {}
     outcontent = {}
     current_milli_time = lambda: int(round(time.time() * 1000))