File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 55import toolz
66from dask .layers import Layer
77
8+ CallableOrNone = Union [Callable , None ]
89
910class MockableDataFrameTreeReduction (Layer ):
1011 """Mockable Tree-Reduction Layer
@@ -48,7 +49,7 @@ class MockableDataFrameTreeReduction(Layer):
4849 npartitions_input : int
4950 concat_func : Callable
5051 tree_node_func : Callable
51- finalize_func : Union [ Callable , None ]
52+ finalize_func : CallableOrNone
5253 split_every : int
5354 split_out : int
5455 output_partitions : list [int ]
@@ -63,7 +64,7 @@ def __init__(
6364 npartitions_input : int ,
6465 concat_func : Callable ,
6566 tree_node_func : Callable ,
66- finalize_func : Callable | None = None ,
67+ finalize_func : CallableOrNone = None ,
6768 split_every : int = 32 ,
6869 split_out : int | None = None ,
6970 output_partitions : list [int ] | None = None ,
You can’t perform that action at this time.
0 commit comments