Skip to content

Commit

Permalink
flake8
Browse files Browse the repository at this point in the history
  • Loading branch information
mrocklin committed Mar 10, 2019
1 parent d27af7a commit 5eeb051
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dask/dataframe/core.py
Expand Up @@ -3812,7 +3812,7 @@ def map_partitions(func, *args, **kwargs):
if transform_divisions and isinstance(dfs[0], Index) and len(dfs) == 1:
try:
divisions = func(
*[pd.Index(arg.divisions) if arg is dfs[0] else arg for arg in args],
*[pd.Index(a.divisions) if a is dfs[0] else a for a in args],
**kwargs
)
if isinstance(divisions, pd.Index):
Expand Down

0 comments on commit 5eeb051

Please sign in to comment.