Skip to content

Commit

Permalink
Merge branch 'main' into kedro-dvc-documentation
Browse files Browse the repository at this point in the history
  • Loading branch information
lrcouto authored Feb 6, 2025
2 parents 80822de + a064c46 commit d957b8d
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions kedro/runner/runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,13 @@
import warnings
from abc import ABC, abstractmethod
from collections import Counter, deque
from concurrent.futures import FIRST_COMPLETED, Executor, ProcessPoolExecutor, wait
from concurrent.futures import (
FIRST_COMPLETED,
Executor,
Future,
ProcessPoolExecutor,
wait,
)
from itertools import chain
from typing import TYPE_CHECKING, Any

Expand Down Expand Up @@ -258,7 +264,7 @@ def _raise_runtime_error(
todo_nodes: set[Node],
done_nodes: set[Node],
ready: set[Node],
done: set[Node] | None,
done: set[Future[Node]] | None,
) -> None:
debug_data = {
"todo_nodes": todo_nodes,
Expand Down

0 comments on commit d957b8d

Please sign in to comment.