Skip to content

Commit

Permalink
undo change
Browse files Browse the repository at this point in the history
  • Loading branch information
jnke2016 committed Sep 25, 2023
1 parent e5f45e7 commit 67fd5c6
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -316,8 +316,8 @@ def __from_edgelist(
is_multigraph=self.properties.multi_edge,
is_symmetric=not self.properties.directed,
)
ddf = ddf.repartition(npartitions=len(workers) * 2)
ddf = ddf.map_partitions(lambda df: df.copy())
ddf = ddf.repartition(npartitions=len(workers) * 2)
ddf = persist_dask_df_equal_parts_per_worker(ddf, _client)
num_edges = len(ddf)
ddf = get_persisted_df_worker_map(ddf, _client)
Expand Down

0 comments on commit 67fd5c6

Please sign in to comment.