MCPcopy
hub / github.com/dask/dask / fuse

Method fuse

dask/dataframe/dask_expr/_expr.py:509–510  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

507 return type(self)(self.frame[predicate], *self.operands[1:])
508
509 def fuse(self):
510 return optimize_blockwise_fusion(self)
511
512 def finalize_compute(self):
513 return FinalizeComputeDF(self)

Callers 6

_taskMethod · 0.45
test_fuse_tasks_keyFunction · 0.45
test_fuse_tasksFunction · 0.45
test_fuse_reject_multiple_outputsFunction · 0.45
test_fused_ensure_only_executed_onceFunction · 0.45
test_fused_dont_hold_in_memory_too_longFunction · 0.45

Calls 1

optimize_blockwise_fusionFunction · 0.85

Tested by 5

test_fuse_tasks_keyFunction · 0.36
test_fuse_tasksFunction · 0.36
test_fuse_reject_multiple_outputsFunction · 0.36
test_fused_ensure_only_executed_onceFunction · 0.36
test_fused_dont_hold_in_memory_too_longFunction · 0.36