pypushflow.tests.concurrent.test_interrupt.test_interrupt

pypushflow.tests.concurrent.test_interrupt.test_interrupt(scaling, max_workers, pool_type, tmpdir)[source]