Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
jnke2016 committed Nov 27, 2023
1 parent fdeaa57 commit 07bcd2e
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 7 deletions.
4 changes: 1 addition & 3 deletions python/cugraph/cugraph/dask/community/egonet.py
Original file line number Diff line number Diff line change
Expand Up @@ -137,9 +137,7 @@ def ego_graph(input_graph, n, radius=1, center=True):
n = dask_cudf.from_cudf(n, npartitions=min(input_graph._npartitions, len(n)))
n = n.astype(n_type)

n = persist_dask_df_equal_parts_per_worker(
n, client, return_type="dict"
)
n = persist_dask_df_equal_parts_per_worker(n, client, return_type="dict")
do_expensive_check = False

result = [
Expand Down
4 changes: 1 addition & 3 deletions python/cugraph/cugraph/dask/community/induced_subgraph.py
Original file line number Diff line number Diff line change
Expand Up @@ -156,9 +156,7 @@ def induced_subgraph(
vertices_type = input_graph.input_df.dtypes[0]

if isinstance(vertices, (cudf.Series, cudf.DataFrame)):
vertices = dask_cudf.from_cudf(
vertices, npartitions=input_graph._npartitions
)
vertices = dask_cudf.from_cudf(vertices, npartitions=input_graph._npartitions)
vertices = vertices.astype(vertices_type)

vertices = persist_dask_df_equal_parts_per_worker(
Expand Down
3 changes: 2 additions & 1 deletion python/cugraph/cugraph/tests/structure/test_graph_mg.py
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,8 @@ def test_create_mg_graph(dask_client, input_combo):
if G.renumbered:
start = G.lookup_internal_vertex_id(start, None)
data_start = persist_dask_df_equal_parts_per_worker(
start, dask_client, return_type="dict")
start, dask_client, return_type="dict"
)

res = [
dask_client.submit(
Expand Down

0 comments on commit 07bcd2e

Please sign in to comment.