HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
ftest_delete_task_life_cycle.py File Reference

Go to the source code of this file.

Namespaces

 ftests.ftest_delete_task_life_cycle
 

Functions

def ftests.ftest_delete_task_life_cycle.create_new_task (taskId, command)
 
def ftests.ftest_delete_task_life_cycle.create_check_task_state (taskId)
 
def ftests.ftest_delete_task_life_cycle.create_get_tasks_status (taskId)
 
def ftests.ftest_delete_task_life_cycle.create_delete_task (deletedTaskId, taskId, host, port)
 
def ftests.ftest_delete_task_life_cycle.get_response_event (clientConnection, timeout)
 

Variables

int ftests.ftest_delete_task_life_cycle.taskId = 10
 
int ftests.ftest_delete_task_life_cycle.wait_response_timeout = 5000
 
string ftests.ftest_delete_task_life_cycle.addr = "192.168.1.135:5501"
 
 ftests.ftest_delete_task_life_cycle.connectBuilder = ConnectionBuilderLight()
 
 ftests.ftest_delete_task_life_cycle.eventBuilder = EventBuilder()
 
 ftests.ftest_delete_task_life_cycle.client = connectBuilder.build(consts.CLIENT_CONNECT, addr, consts.TCP_TYPE)
 
 ftests.ftest_delete_task_life_cycle.new_task_event = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task(taskId, "ls -la"))
 
 ftests.ftest_delete_task_life_cycle.check_task_state_event = eventBuilder.build(EVENT_TYPES.CHECK_TASK_STATE, create_check_task_state(taskId))
 
 ftests.ftest_delete_task_life_cycle.get_tasks_status_event = eventBuilder.build(EVENT_TYPES.GET_TASK_STATUS, create_get_tasks_status(taskId))
 
def ftests.ftest_delete_task_life_cycle.response_event = get_response_event(client, wait_response_timeout)
 
 ftests.ftest_delete_task_life_cycle.host = None
 
 ftests.ftest_delete_task_life_cycle.port = None
 
 ftests.ftest_delete_task_life_cycle.delete_task_event
 
 ftests.ftest_delete_task_life_cycle.get_tasks_status_event1 = eventBuilder.build(EVENT_TYPES.GET_TASK_STATUS, create_get_tasks_status(taskId + 1))