Model¶
tdworkflow.attempt module¶
-
class
tdworkflow.attempt.
Attempt
(id: int, sessionId: int = -1, sessionUuid: str = '', sessionTime: datetime.datetime = None, workflow: tdworkflow.workflow.Workflow = None, project: tdworkflow.project.Project = None, index: int = -1, retryAttemptName: str = '', done: bool = False, success: bool = False, cancelRequested: bool = False, params: Dict = None, createdAt: datetime.datetime = None, finishedAt: datetime.datetime = None, status: str = '')¶ Bases:
tdworkflow.resource.Resource
-
cancelRequested
= False¶
-
cancel_requested
¶
-
createdAt
= None¶
-
done
= False¶
-
finished
()¶
-
finishedAt
= None¶
-
finished_at
¶
-
index
= -1¶
-
params
= None¶
-
project
= None¶
-
retryAttemptName
= ''¶
-
retry_attempt_name
¶
-
sessionId
= -1¶
-
sessionTime
= None¶
-
sessionUuid
= ''¶
-
session_id
¶
-
session_time
¶
-
session_uuid
¶
-
status
= ''¶
-
success
= False¶
-
update
(**args)¶
-
workflow
= None¶
-
tdworkflow.log module¶
tdworkflow.project module¶
-
class
tdworkflow.project.
Project
(id: int, name: str, revision: str = '', archiveType: str = '', archiveMd5: str = '', createdAt: datetime.datetime = None, deletedAt: datetime.datetime = None, updatedAt: datetime.datetime = None)¶ Bases:
tdworkflow.resource.Resource
-
archiveMd5
= ''¶
-
archiveType
= ''¶
-
archive_md5
¶
-
archive_type
¶
-
createdAt
= None¶
-
created_at
¶
-
deletedAt
= None¶
-
deleted_at
¶
-
revision
= ''¶
-
updatedAt
= None¶
-
updated_at
¶
-
tdworkflow.revision module¶
-
class
tdworkflow.revision.
Revision
(revision: str, createdAt: datetime.datetime = None, archiveType: str = '', archiveMd5: str = '', userInfo: Dict = None)¶ Bases:
tdworkflow.resource.Resource
-
archiveMd5
= ''¶
-
archiveType
= ''¶
-
archive_md5
¶
-
archive_type
¶
-
createdAt
= None¶
-
created_at
¶
-
userInfo
= None¶
-
tdworkflow.schedule module¶
-
class
tdworkflow.schedule.
Schedule
(id: int, project: tdworkflow.project.Project, workflow: tdworkflow.workflow.Workflow, createdAt: datetime.datetime = None, updatedAt: datetime.datetime = None, disabledAt: datetime.datetime = None, nextScheduleTime: Dict = None, nextRunTime: datetime.datetime = None)¶ Bases:
tdworkflow.resource.Resource
-
createdAt
= None¶
-
created_at
¶
-
disabledAt
= None¶
-
disabled_at
¶
-
nextRunTime
= None¶
-
nextScheduleTime
= None¶
-
next_run_time
¶
-
next_schedule_time
¶
-
updatedAt
= None¶
-
updated_at
¶
-
tdworkflow.session module¶
-
class
tdworkflow.session.
Session
(id: int, project: tdworkflow.project.Project, workflow: tdworkflow.workflow.Workflow, sessionUuid: str, sessionTime: datetime.datetime = None, lastAttempt: tdworkflow.attempt.Attempt = None)¶ Bases:
tdworkflow.resource.Resource
-
lastAttempt
= None¶
-
last_attempt
¶
-
sessionTime
= None¶
-
session_time
¶
-
session_uuid
¶
-
tdworkflow.task module¶
-
class
tdworkflow.task.
Task
(id: int, state: str, updatedAt: datetime.datetime = None, fullName: str = '', parentId: int = None, upstreams: List[int] = None, retryAt: datetime.datetime = None, config: Dict = None, exportParams: Dict = None, storeParams: Dict = None, stateParams: Dict = None, error: Dict = None, startedAt: datetime.datetime = None, cancelRequested: bool = False, isGroup: bool = False)¶ Bases:
tdworkflow.resource.Resource
-
cancelRequested
= False¶
-
cancel_requested
¶
-
config
= None¶
-
error
= None¶
-
exportParams
= None¶
-
export_params
¶
-
fullName
= ''¶
-
full_name
¶
-
group
¶
-
isGroup
= False¶
-
parentId
= None¶
-
parent_id
¶
-
retryAt
= None¶
-
retry_at
¶
-
startedAt
= None¶
-
started_at
¶
-
stateParams
= None¶
-
state_params
¶
-
storeParams
= None¶
-
store_params
¶
-
updatedAt
= None¶
-
updated_at
¶
-
upstreams
= None¶
-
-
class
tdworkflow.task.
TaskEncoder
(*, skipkeys=False, ensure_ascii=True, check_circular=True, allow_nan=True, sort_keys=False, indent=None, separators=None, default=None)¶ Bases:
json.encoder.JSONEncoder
-
default
(obj)¶ Implement this method in a subclass such that it returns a serializable object for
o
, or calls the base implementation (to raise aTypeError
).For example, to support arbitrary iterators, you could implement default like this:
def default(self, o): try: iterable = iter(o) except TypeError: pass else: return list(iterable) # Let the base class default method raise the TypeError return JSONEncoder.default(self, o)
-
tdworkflow.workflow module¶
-
class
tdworkflow.workflow.
Workflow
(id: int, name: str, project: tdworkflow.project.Project = None, timezone: str = '', config: dict = None, revision: str = '', createdAt: datetime.datetime = None, deletedAt: datetime.datetime = None, updatedAt: datetime.datetime = None)¶ Bases:
tdworkflow.resource.Resource
-
config
= None¶
-
createdAt
= None¶
-
created_at
¶
-
deletedAt
= None¶
-
deleted_at
¶
-
project
= None¶
-
revision
= ''¶
-
timezone
= ''¶
-
updatedAt
= None¶
-
updated_at
¶
-