Skip to main content

multiprocessing.tasks

Queue​

Any​

Callable​

Optional​

Union​

glasswall​

Task Objects​

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 Objects​

class TaskResult()

timeout_seconds​

memory_limit_in_gib​

start_time​

end_time​

elapsed_time​

out_of_memory​

timed_out​

max_memory_used_in_gib​

exit_code​

__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