task_watcher

TaskWatcher

class TaskWatcher()

process

process = None

start_time

start_time = None

end_time

end_time = None

elapsed_time

elapsed_time = None

__init__

def __init__(task: Task,
             task_results_queue: "Queue[TaskResult]",
             timeout_seconds: Optional[float] = None,
             memory_limit_in_gib: Optional[float] = None,
             sleep_time: float = 0.001,
             memory_limit_polling_rate: float = 0.1,
             auto_start: bool = True)

start_task

def start_task() -> None

terminate_task

def terminate_task() -> None

terminate_task_with_timeout

def terminate_task_with_timeout() -> None

terminate_task_with_out_of_memory

def terminate_task_with_out_of_memory() -> None

clean_watcher_queue

def clean_watcher_queue()

watch_task

def watch_task() -> None

update_queue

def update_queue() -> None