We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fa7bee9 commit 2d9f84aCopy full SHA for 2d9f84a
2 files changed
src/executorlib/task_scheduler/interactive/dependency.py
@@ -329,9 +329,7 @@ def _execute_tasks_with_dependencies(
329
refresh_rate=refresh_rate,
330
)
331
elif task_return_dict is not None:
332
- future_lookup_dict = (
333
- {}
334
- ) # we need this future dict later on to resolve the dependencies
+ future_lookup_dict = {} # we need this future dict later on to resolve the dependencies
335
for k, v in task_return_dict.items():
336
future_lookup_dict[k] = executor.submit(
337
fn=v["fn"],
src/executorlib/task_scheduler/interactive/onetoone.py
@@ -1,7 +1,6 @@
1
import queue
2
from concurrent.futures import Future
3
from threading import Thread
4
-from time import sleep
5
from typing import Callable, Optional
6
7
from executorlib.standalone.command import get_interactive_execute_command
0 commit comments