(default_app)
| 48 | assert isinstance(executor._self, concurrent.futures._base.Executor) |
| 49 | |
| 50 | def test_thread_executor_init(default_app): |
| 51 | default_app.config['EXECUTOR_TYPE'] = 'thread' |
| 52 | executor = Executor(default_app) |
| 53 | assert isinstance(executor._self, concurrent.futures.ThreadPoolExecutor) |
| 54 | assert isinstance(executor, concurrent.futures.ThreadPoolExecutor) |
| 55 | |
| 56 | def test_process_executor_init(default_app): |
| 57 | default_app.config['EXECUTOR_TYPE'] = 'process' |