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