MCPcopy Create free account
hub / github.com/dask/dask / _simplify_up

Method _simplify_up

dask/dataframe/dask_expr/_shuffle.py:1302–1316  ·  view source on GitHub ↗
(self, parent, dependents)

Source from the content-addressed store, hash-verified

1300 return tuple(self.new_divisions)
1301
1302 def _simplify_up(self, parent, dependents):
1303 if isinstance(parent, Projection):
1304 columns = determine_column_projection(
1305 self,
1306 parent,
1307 dependents,
1308 additional_columns=_convert_to_list(self.other),
1309 )
1310 if self.frame.columns == columns:
1311 return
1312 columns = [col for col in self.frame.columns if col in columns]
1313 return type(parent)(
1314 type(self)(self.frame[columns], *self.operands[1:]),
1315 parent.operand("columns"),
1316 )
1317
1318
1319divisions_lru = LRU(10) # type: ignore

Callers

nothing calls this directly

Calls 3

_convert_to_listFunction · 0.90
operandMethod · 0.80

Tested by

no test coverage detected