diff --git a/nx_parallel/algorithms/approximation/connectivity.py b/nx_parallel/algorithms/approximation/connectivity.py index 44f966e..df23745 100644 --- a/nx_parallel/algorithms/approximation/connectivity.py +++ b/nx_parallel/algorithms/approximation/connectivity.py @@ -4,7 +4,9 @@ import nx_parallel as nxp from networkx.algorithms.approximation.connectivity import local_node_connectivity -__all__ = ["all_pairs_node_connectivity",] +__all__ = [ + "all_pairs_node_connectivity", +] def all_pairs_node_connectivity(G, nbunch=None, cutoff=None): @@ -42,7 +44,8 @@ def _calculate_all_pairs_node_connectivity_subset(chunk): pair_chunks = nxp.chunks(pairs, num_in_chunk) Parallel(n_jobs=total_cores, backend="threading")( - delayed(_calculate_all_pairs_node_connectivity_subset)(chunk) for chunk in pair_chunks + delayed(_calculate_all_pairs_node_connectivity_subset)(chunk) + for chunk in pair_chunks ) return all_pairs diff --git a/nx_parallel/algorithms/shortest_paths/weighted.py b/nx_parallel/algorithms/shortest_paths/weighted.py index 0630e9d..af535f0 100644 --- a/nx_parallel/algorithms/shortest_paths/weighted.py +++ b/nx_parallel/algorithms/shortest_paths/weighted.py @@ -85,7 +85,7 @@ def _calculate_shortest_paths_length_subset(n): def all_pairs_bellman_ford_path(G, weight="weight"): - """The parallel computation is implemented by computing the + """The parallel computation is implemented by computing the shortest paths for each node concurrently. networkx.all_pairs_bellman_ford_path : https://networkx.org/documentation/stable/reference/algorithms/generated/networkx.algorithms.shortest_paths.weighted.all_pairs_bellman_ford_path.html#all-pairs-bellman-ford-path diff --git a/nx_parallel/interface.py b/nx_parallel/interface.py index a91c873..2484530 100644 --- a/nx_parallel/interface.py +++ b/nx_parallel/interface.py @@ -17,7 +17,9 @@ tournament_is_strongly_connected, ) from nx_parallel.algorithms.vitality import closeness_vitality -from nx_parallel.algorithms.approximation.connectivity import all_pairs_node_connectivity +from nx_parallel.algorithms.approximation.connectivity import ( + all_pairs_node_connectivity, +) __all__ = ["Dispatcher", "ParallelGraph"]