Skip to content

Commit

Permalink
Improve incomplete type hints
Browse files Browse the repository at this point in the history
  • Loading branch information
disrupted committed Jul 29, 2024
1 parent 9b73dec commit ecff6b2
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kpops/pipeline/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ async def run_graph_tasks(pending_tasks: list[Awaitable[None]]) -> None:

layers_graph: list[list[str]] = list(nx.bfs_layers(graph, root_node))

sorted_tasks = []
sorted_tasks: list[Awaitable[None]] = []
for layer in layers_graph[1:]:
if parallel_tasks := self.__get_parallel_tasks_from(layer, runner):
sorted_tasks.append(run_parallel_tasks(parallel_tasks))
Expand Down

0 comments on commit ecff6b2

Please sign in to comment.