(default_cluster)
| 160 | @pytest.mark.skipif(sys.platform == 'win32', |
| 161 | reason='Not yet concurrent-safe on Windows (DCOS_OSS-4843)') |
| 162 | def test_plugin_concurrent_invocation(default_cluster): |
| 163 | _install_test_plugin() |
| 164 | |
| 165 | with futures.ThreadPoolExecutor() as pool: |
| 166 | cmds = [pool.submit(exec_cmd, ['dcos', 'test', 'arg']) for _ in range(50)] |
| 167 | |
| 168 | completed, _ = futures.wait(cmds, timeout=30) |
| 169 | assert len(completed) == 50 |
| 170 | |
| 171 | for cmd in completed: |
| 172 | code, out, err = cmd.result() |
| 173 | assert code == 0, out + err |
| 174 | |
| 175 | |
| 176 | def test_plugin_verbosity(default_cluster): |
nothing calls this directly
no test coverage detected