From 25c382d2951d913639456223b058c206dd7ebc1d Mon Sep 17 00:00:00 2001 From: jnke2016 Date: Tue, 16 Jan 2024 03:23:59 -0800 Subject: [PATCH] fix style --- .../simpleDistributedGraph.py | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/python/cugraph/cugraph/structure/graph_implementation/simpleDistributedGraph.py b/python/cugraph/cugraph/structure/graph_implementation/simpleDistributedGraph.py index afebfee03d6..8ec613f7cbb 100644 --- a/python/cugraph/cugraph/structure/graph_implementation/simpleDistributedGraph.py +++ b/python/cugraph/cugraph/structure/graph_implementation/simpleDistributedGraph.py @@ -848,7 +848,9 @@ def _call_plc_two_hop_neighbors(sID, mg_graph_x, start_vertices): start_vertices = start_vertices.astype(start_vertices_type) - def create_iterable_args(session_id, input_graph, start_vertices=None, npartitions=None): + def create_iterable_args( + session_id, input_graph, start_vertices=None, npartitions=None + ): session_id_it = [session_id] * npartitions graph_it = input_graph.values() start_vertices = cp.array_split(start_vertices.values, npartitions) @@ -860,10 +862,13 @@ def create_iterable_args(session_id, input_graph, start_vertices=None, npartitio result = _client.map( _call_plc_two_hop_neighbors, - *create_iterable_args( - Comms.get_session_id(), self._plc_graph, start_vertices, self._npartitions - ), - pure=False, + *create_iterable_args( + Comms.get_session_id(), + self._plc_graph, + start_vertices, + self._npartitions, + ), + pure=False, ) else: @@ -892,7 +897,8 @@ def convert_to_cudf(cp_arrays): return df cudf_result = [ - _client.submit(convert_to_cudf, cp_arrays, pure=False) for cp_arrays in result + _client.submit(convert_to_cudf, cp_arrays, pure=False) + for cp_arrays in result ] wait(cudf_result)