Model¶

tdworkflow.attempt module¶

class tdworkflow.attempt.Attempt(id: int, sessionId: int = -1, sessionUuid: str = '', sessionTime: str = '', 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: str = '', finishedAt: str = '')¶

Bases: object

cancelRequested = False¶

cancel_requested¶

createdAt = ''¶

done = False¶

finished()¶

finishedAt = ''¶

finished_at¶

index = -1¶

params = None¶

project = None¶

retryAttemptName = ''¶

retry_attempt_name¶

sesesion_time¶

sessionId = -1¶

sessionTime = ''¶

sessionUuid = ''¶

session_id¶

session_uuid¶

success = False¶

workflow = None¶

tdworkflow.log module¶

class tdworkflow.log.LogFile(fileName: str, taskName: str, fileTime: int, direct: Dict, fileSize: int, agentId: str)¶

Bases: object

agent_id¶

file_name¶

file_size¶

file_time¶

taks_name¶

tdworkflow.project module¶

class tdworkflow.project.Project(id: int, name: str, revision: str = '', archiveType: str = '', archiveMd5: str = '', createdAt: str = '', deletedAt: str = '', updatedAt: str = '')¶

Bases: object

archiveMd5 = ''¶

archiveType = ''¶

archive_md5¶

archive_type¶

createdAt = ''¶

created_at¶

deletedAt = ''¶

deleted_at¶

revision = ''¶

updatedAt = ''¶

updated_at¶

tdworkflow.revision module¶

class tdworkflow.revision.Revision(revision: str, createdAt: str = '', archiveType: str = '', archiveMd5: str = '', userInfo: Dict = None)¶

Bases: object

archiveMd5 = ''¶

archiveType = ''¶

archive_md5¶

archive_type¶

createdAt = ''¶

created_at¶

userInfo = None¶

tdworkflow.schedule module¶

class tdworkflow.schedule.Schedule(id: int, project: tdworkflow.project.Project, workflow: tdworkflow.workflow.Workflow, createdAt: str = '', updatedAt: str = '', disabledAt: str = '', nextScheduleTime: Dict = None, nextRunTime: str = '')¶

Bases: object

createdAt = ''¶

created_at¶

disabledAt = ''¶

disabled_at¶

nextRunTime = ''¶

nextScheduleTime = None¶

updatedAt = ''¶

updated_at¶

class tdworkflow.schedule.ScheduleAttempt(id: int, attempts: List[tdworkflow.attempt.Attempt], project: tdworkflow.project.Project = None, workflow: tdworkflow.workflow.Workflow = None)¶

Bases: object

project = None¶

workflow = None¶

tdworkflow.session module¶

class tdworkflow.session.Session(id: int, project: tdworkflow.project.Project, workflow: tdworkflow.workflow.Workflow, sessionUuid: str, sessionTime: str, lastAttempt: tdworkflow.attempt.Attempt)¶

Bases: object

last_attempt¶

session_time¶

session_uuid¶

tdworkflow.workflow module¶

class tdworkflow.workflow.Workflow(id: int, name: str, project: tdworkflow.project.Project = None, timezone: str = '', config: dict = None, revision: str = '', createdAt: str = '', deletedAt: str = '', updatedAt: str = '')¶

Bases: object

config = None¶

createdAt = ''¶

created_at¶

deletedAt = ''¶

deleted_at¶

project = None¶

revision = ''¶

timezone = ''¶

updatedAt = ''¶

updated_at¶