ftest_drce_cluster_requests.py

Go to the documentation of this file.

'''
Created on Mar 21, 2014

@author: igor
'''

from drce.DRCEManager import DRCEManager, HostParams
from drce.Commands import TaskExecuteRequest
 

if __name__ == '__main__':
    timeout = 1000
    request_id = "1"
    host_params = HostParams("127.0.0.1", 10021)    
    task_execute_request = TaskExecuteRequest(request_id) 
        
    drceManager = DRCEManager()    
    drceManager.activate_host(host_params)
    
    taskResponse = drceManager.process(task_execute_request, timeout)
    
    print "response item count ", len(taskResponse.items)
    for item in taskResponse.items:
        print item.__dict__
    
    print "OK"