Task Run¶
It can be imported from fluid.scheduler
:
fluid.scheduler.TaskRun
pydantic-model
¶
Bases: BaseModel
, Generic[TP]
A TaskRun contains all the data generated by a Task run
This model is never initialized directly, it is created by the TaskManager
Fields:
-
id
(str
) -
task
(Task
) -
priority
(TaskPriority
) -
params
(TP
) -
state
(TaskState
) -
task_manager
(TaskManager
) -
queued
(datetime | None
) -
start
(datetime | None
) -
end
(datetime | None
) -
logger
(Logger
) -
in_queue
(timedelta | None
) -
duration
(timedelta | None
) -
duration_ms
(float | None
) -
total
(timedelta | None
) -
name
(str
) -
name_id
(str
) -
is_done
(bool
) -
is_failure
(bool
) -
deps
(Any
)
execute
async
¶
Execute the task