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.EventObjects.FetchAvailabelTaskIds Class Reference

FetchAvailabelTaskIds event object, for fetch available task id. More...

Inheritance diagram for dtm.EventObjects.FetchAvailabelTaskIds:
Collaboration diagram for dtm.EventObjects.FetchAvailabelTaskIds:

Public Member Functions

def __init__ (self, fetchNum, fetchAdditionalFields=False, criterions=None, tableName=TABLE_NAME_DEFAULT)
 constructor initialize task's fields More...
 
def fillCriterions (self)
 fillCriterions default initialize criterions method More...
 
- Public Member Functions inherited from app.Utils.JsonSerializable
def __init__ (self)
 
def toJSON (self)
 

Public Attributes

 criterions
 
 fetchNum
 
 fetchAdditionalFields
 
 tableName
 

Static Public Attributes

string TABLE_NAME_DEFAULT = "task_back_log_scheme"
 

Additional Inherited Members

- Static Public Member Functions inherited from app.Utils.JsonSerializable
def json_serial (obj)
 

Detailed Description

FetchAvailabelTaskIds event object, for fetch available task id.

Definition at line 1094 of file EventObjects.py.

Constructor & Destructor Documentation

◆ __init__()

def dtm.EventObjects.FetchAvailabelTaskIds.__init__ (   self,
  fetchNum,
  fetchAdditionalFields = False,
  criterions = None,
  tableName = TABLE_NAME_DEFAULT 
)

constructor initialize task's fields

Parameters
fetchNumids limit
fetchAdditionalFieldsmeans that we will extract addition fields from tasks kv-db database
criterionsexctraction criterions

Definition at line 1103 of file EventObjects.py.

1103  def __init__(self, fetchNum, fetchAdditionalFields=False, criterions=None, tableName=TABLE_NAME_DEFAULT):
1104  super(FetchAvailabelTaskIds, self).__init__()
1105  self.criterions = criterions
1106  self.fetchNum = fetchNum
1107  self.fetchAdditionalFields = fetchAdditionalFields
1108  self.tableName = tableName
1109  self.fillCriterions()
1110 
1111 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ fillCriterions()

def dtm.EventObjects.FetchAvailabelTaskIds.fillCriterions (   self)

fillCriterions default initialize criterions method

Definition at line 1113 of file EventObjects.py.

1113  def fillCriterions(self):
1114  if self.criterions is None:
1115  self.criterions = {}
1116  if app.SQLCriterions.CRITERION_WHERE not in self.criterions or \
1117  self.criterions[app.SQLCriterions.CRITERION_WHERE] is None:
1118  self.criterions[app.SQLCriterions.CRITERION_WHERE] = "deleteTaskId = 0"
1119  if app.SQLCriterions.CRITERION_ORDER not in self.criterions or \
1120  self.criterions[app.SQLCriterions.CRITERION_ORDER] is None:
1121  self.criterions[app.SQLCriterions.CRITERION_ORDER] = "rDate"
1122  if app.SQLCriterions.CRITERION_LIMIT not in self.criterions or \
1123  self.criterions[app.SQLCriterions.CRITERION_LIMIT] is None:
1124  self.criterions[app.SQLCriterions.CRITERION_LIMIT] = self.fetchNum
1125 
1126 
1127 

Member Data Documentation

◆ criterions

dtm.EventObjects.FetchAvailabelTaskIds.criterions

Definition at line 1105 of file EventObjects.py.

◆ fetchAdditionalFields

dtm.EventObjects.FetchAvailabelTaskIds.fetchAdditionalFields

Definition at line 1107 of file EventObjects.py.

◆ fetchNum

dtm.EventObjects.FetchAvailabelTaskIds.fetchNum

Definition at line 1106 of file EventObjects.py.

◆ TABLE_NAME_DEFAULT

string dtm.EventObjects.FetchAvailabelTaskIds.TABLE_NAME_DEFAULT = "task_back_log_scheme"
static

Definition at line 1096 of file EventObjects.py.

◆ tableName

dtm.EventObjects.FetchAvailabelTaskIds.tableName

Definition at line 1108 of file EventObjects.py.


The documentation for this class was generated from the following file: