tasks
Task
class Task()
__init__
def __init__(func: Callable,
args: Optional[tuple] = None,
kwargs: Optional[dict] = None)
__eq__
def __eq__(other)
__hash__
def __hash__()
__repr__
def __repr__()
TaskResult
class TaskResult()
timeout_seconds
timeout_seconds = None
memory_limit_in_gib
memory_limit_in_gib = None
start_time
start_time = None
end_time
end_time = None
elapsed_time
elapsed_time = None
out_of_memory
out_of_memory = None
timed_out
timed_out = None
max_memory_used_in_gib
max_memory_used_in_gib = None
exit_code
exit_code = None
__init__
def __init__(task: Task,
success: bool,
result: Any = None,
exception: Union[Exception, None] = None)
__eq__
def __eq__(other)
__hash__
def __hash__()
__repr__
def __repr__()
execute_task_and_put_in_queue
def execute_task_and_put_in_queue(task: Task,
queue: "Queue[TaskResult]") -> None