Skip to content

Commit 0f27bc7

Browse files
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
1 parent 43024b0 commit 0f27bc7

3 files changed

Lines changed: 8 additions & 6 deletions

File tree

src/executorlib/backend/executor_nested.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ def __init__(self):
1414
@property
1515
def tasks(self):
1616
return self._tasks_dict
17-
17+
1818
def batched(
1919
self,
2020
iterable: list[Future],
@@ -31,7 +31,7 @@ def batched(
3131
list[Future]: list of future objects one for each batch
3232
"""
3333
raise NotImplementedError("The batched method is not implemented.")
34-
34+
3535
def map(
3636
self,
3737
fn: Callable,
@@ -104,8 +104,10 @@ def submit( # type: ignore
104104
"kwargs": kwargs,
105105
"resource_dict": resource_dict,
106106
"dependencies": [
107-
self._future_dict[future_dependency]
108-
for future_dependency in get_future_objects_from_input(args=args, kwargs=kwargs)
107+
self._future_dict[future_dependency]
108+
for future_dependency in get_future_objects_from_input(
109+
args=args, kwargs=kwargs
110+
)
109111
],
110112
}
111113
return f

src/executorlib/backend/interactive_parallel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ def main() -> None:
9797
interface_send(
9898
socket=socket,
9999
result_dict={
100-
"result": output_reply,
100+
"result": output_reply,
101101
"tasks_nested": memory["executorlib_executor"].tasks,
102102
},
103103
)

src/executorlib/backend/interactive_serial.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ def evaluate_cmd(argument_lst: Optional[list[str]] = None):
7272
interface_send(
7373
socket=socket,
7474
result_dict={
75-
"result": output,
75+
"result": output,
7676
"tasks_nested": memory["executorlib_executor"].tasks,
7777
},
7878
)

0 commit comments

Comments
 (0)