executorlib.task_scheduler.interactive.shared

Functions

execute_task_dict(task_dict, future_obj, ...)	Execute the task in the task_dict by communicating it via the interface.
reset_task_dict(future_obj, future_queue, ...)	Reset the task dictionary for resubmission to the queue.
task_done(future_queue)	Mark the current task as done in the current queue.