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
dtm.TasksManager Namespace Reference

Classes

class  TaskNoPresentErr
 
class  TasksManager
 

Variables

 logger = logging.getLogger(LOGGER_NAME)
 
 TaskStep = namedtuple("TaskStep", "ok_callback err_callback desc eventNewTask")
 
 TaskRecord = namedtuple("TaskRecord", "tasksteps event responseEventType")
 
int STEP_SEND_TO_TASKS_DATA_MANAGER = 1
 
int STEP_ADD_TO_INTERNAL_STRUCTURES = 2
 
int STEP_SEND_TO_SCHEDULER = 3
 
int STEP_UPDATE_STATE = 4
 

Detailed Description

@package: dtm
@author igor, bgv
@link: http://hierarchical-cluster-engine.com/
@copyright: Copyright © 2013-2014 IOIX Ukraine
@license: http://hierarchical-cluster-engine.com/license/
@since: 0.1

Variable Documentation

◆ logger

dtm.TasksManager.logger = logging.getLogger(LOGGER_NAME)

Definition at line 38 of file TasksManager.py.

◆ STEP_ADD_TO_INTERNAL_STRUCTURES

int dtm.TasksManager.STEP_ADD_TO_INTERNAL_STRUCTURES = 2

Definition at line 50 of file TasksManager.py.

◆ STEP_SEND_TO_SCHEDULER

int dtm.TasksManager.STEP_SEND_TO_SCHEDULER = 3

Definition at line 51 of file TasksManager.py.

◆ STEP_SEND_TO_TASKS_DATA_MANAGER

int dtm.TasksManager.STEP_SEND_TO_TASKS_DATA_MANAGER = 1

Definition at line 49 of file TasksManager.py.

◆ STEP_UPDATE_STATE

int dtm.TasksManager.STEP_UPDATE_STATE = 4

Definition at line 52 of file TasksManager.py.

◆ TaskRecord

dtm.TasksManager.TaskRecord = namedtuple("TaskRecord", "tasksteps event responseEventType")

Definition at line 44 of file TasksManager.py.

◆ TaskStep

dtm.TasksManager.TaskStep = namedtuple("TaskStep", "ok_callback err_callback desc eventNewTask")

Definition at line 41 of file TasksManager.py.