executorlib.task_scheduler.interactive.shared.reset_task_dict

executorlib.task_scheduler.interactive.shared.reset_task_dict(future_obj: Future, future_queue: Queue, task_dict: dict)

Reset the task dictionary for resubmission to the queue.

Parameters:

• future_obj (Future) – A Future representing the given call.

• future_queue (queue) – Queue of task dictionaries waiting for execution.

• task_dict (dict) – task submitted to the executor as dictionary. This dictionary has the following keys {“fn”: Callable, “args”: (), “kwargs”: {}, “resource_dict”: {}}

Returns:

True if the task was submitted successfully, False otherwise.

Return type:

bool