Skip to content

Commit 9efd8a5

Browse files
committed
If the cache is empty execute the task again
1 parent 24f0571 commit 9efd8a5

File tree

1 file changed

+13
-4
lines changed

1 file changed

+13
-4
lines changed

executorlib/interactive/shared.py

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -632,7 +632,16 @@ def _execute_task_with_cache(
632632
data_dict["output"] = future.result()
633633
dump(file_name=file_name, data_dict=data_dict)
634634
else:
635-
_, result = get_output(file_name=file_name)
636-
future = task_dict["future"]
637-
future.set_result(result)
638-
future_queue.task_done()
635+
exe_flag, result = get_output(file_name=file_name)
636+
if exe_flag:
637+
future = task_dict["future"]
638+
future.set_result(result)
639+
future_queue.task_done()
640+
else:
641+
_execute_task(
642+
interface=interface,
643+
task_dict=task_dict,
644+
future_queue=future_queue,
645+
)
646+
data_dict["output"] = future.result()
647+
dump(file_name=file_name, data_dict=data_dict)

0 commit comments

Comments
 (0)