src/neco/execution/tasks.py

   1
   2 class TaskStatus:
   3     NEW = 0
   4     RETRY = 1
   5     SUCCESS = 2
   6     FAIL = 3
   7     RECYCLE = 4
   8
   9 class Task(object):
  10     def __init__(self, timestamp, callback, args, kwargs):
  11         self.id = None
  12         self.timestamp = timestamp
  13         self.callback = callback
  14         self.args = args
  15         self.kwargs = kwargs
  16         self.result = None
  17         self.status = TaskStatus.NEW
  18