Model¶

tdworkflow.attempt module¶

class tdworkflow.attempt.Attempt(id: int, sessionId: int = -1, sessionUuid: str = '', sessionTime: Optional[datetime.datetime] = None, workflow: Optional[tdworkflow.workflow.Workflow] = None, project: Optional[tdworkflow.project.Project] = None, index: int = -1, retryAttemptName: str = '', done: bool = False, success: bool = False, cancelRequested: bool = False, params: Optional[Dict[str, Any]] = None, createdAt: Optional[datetime.datetime] = None, finishedAt: Optional[datetime.datetime] = None, status: str = '')¶

Bases: tdworkflow.resource.Resource

cancelRequested = False¶

cancel_requested¶

createdAt = None¶

done = False¶

finished() → bool¶

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) → None¶

workflow = None¶

tdworkflow.log module¶

class tdworkflow.log.LogFile(fileName: str, taskName: str, direct: Dict[Any, Any], fileSize: int, agentId: str, fileTime: Optional[datetime.datetime] = None)¶

Bases: tdworkflow.resource.Resource

agent_id¶

fileTime = None¶

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: Optional[datetime.datetime] = None, deletedAt: Optional[datetime.datetime] = None, updatedAt: Optional[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: Optional[datetime.datetime] = None, archiveType: str = '', archiveMd5: str = '', userInfo: Optional[Dict[str, Any]] = 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: Optional[datetime.datetime] = None, updatedAt: Optional[datetime.datetime] = None, disabledAt: Optional[datetime.datetime] = None, nextScheduleTime: Optional[Dict[str, Union[int, str, Dict[str, Any]]]] = None, nextRunTime: Optional[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¶

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

Bases: tdworkflow.resource.Resource

project = None¶

workflow = None¶

tdworkflow.session module¶

class tdworkflow.session.Session(id: int, project: tdworkflow.project.Project, workflow: tdworkflow.workflow.Workflow, sessionUuid: str, sessionTime: Optional[datetime.datetime] = None, lastAttempt: Optional[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: Optional[datetime.datetime] = None, fullName: str = '', parentId: Optional[int] = None, upstreams: Optional[List[int]] = None, retryAt: Optional[datetime.datetime] = None, config: Optional[Dict[str, Any]] = None, exportParams: Optional[Dict[str, Any]] = None, storeParams: Optional[Dict[str, Any]] = None, stateParams: Optional[Dict[str, Any]] = None, error: Optional[Dict[str, Any]] = None, startedAt: Optional[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: Any) → Any¶

Implement this method in a subclass such that it returns a serializable object for o, or calls the base implementation (to raise a TypeError).

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: Optional[tdworkflow.project.Project] = None, timezone: str = '', config: Optional[Dict[str, Any]] = None, revision: str = '', createdAt: Optional[datetime.datetime] = None, deletedAt: Optional[datetime.datetime] = None, updatedAt: Optional[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¶