pypushflow.concurrent.scaling.ScalingPool¶
- class pypushflow.concurrent.scaling.ScalingPool(wait_on_exit=True, wait_on_exit_timeout=None, interrupt_on_exit=False, pool_type=None, **pool_options)[source]¶
Bases:
BasePool
- Parameters:
wait_on_exit (
bool
) –wait_on_exit_timeout (
Optional
[Number
]) –interrupt_on_exit (
bool
) –pool_type (
Optional
[str
]) –
- apply_async(fn, callback=None, error_callback=None, args=(), kwargs=None)[source]¶
- Parameters:
fn (
Callable
) –callback (
Optional
[Callable
]) –error_callback (
Optional
[Callable
]) –
- shutdown(block=False, timeout=None, interrupt=False)¶
Cleanup all resources. Waits for tasks to finish unless interrupt=True.
- Parameters:
block (
bool
) –timeout (
Optional
[Number
]) –interrupt (
bool
) –
- Return type:
None