diff options
| author | John Szakmeister <john@szakmeister.net> | 2015-12-23 06:00:38 -0500 |
|---|---|---|
| committer | John Szakmeister <john@szakmeister.net> | 2015-12-23 06:00:38 -0500 |
| commit | 344a215c8aa4c74f70ecaa70ed54c5158da59757 (patch) | |
| tree | 00ba0b2746d1820d3ed6319b0faf150a0e88c67e | |
| parent | 0f592c4b022bf3226bd970ccc8c09fea899b2960 (diff) | |
| parent | 02f7d848e4924264f81d3753673db53a93ae1c13 (diff) | |
| download | nose-344a215c8aa4c74f70ecaa70ed54c5158da59757.tar.gz | |
Merge pull request #977 from harrykao/multiprocess_loader
Use a new test loader for each queue item.
| -rw-r--r-- | nose/plugins/multiprocess.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/nose/plugins/multiprocess.py b/nose/plugins/multiprocess.py index 2cae744..135d69c 100644 --- a/nose/plugins/multiprocess.py +++ b/nose/plugins/multiprocess.py @@ -668,8 +668,6 @@ def __runner(ix, testQueue, resultQueue, currentaddr, currentstart, config.plugins.configure(config.options,config) config.plugins.begin() log.debug("Worker %s executing, pid=%d", ix,os.getpid()) - loader = loaderClass(config=config) - loader.suiteClass.suiteClass = NoSharedFixtureContextSuite def get(): return testQueue.get(timeout=config.multiprocess_timeout) @@ -702,6 +700,8 @@ def __runner(ix, testQueue, resultQueue, currentaddr, currentstart, log.exception('Worker %d STOPPED',ix) break result = makeResult() + loader = loaderClass(config=config) + loader.suiteClass.suiteClass = NoSharedFixtureContextSuite test = loader.loadTestsFromNames([test_addr]) test.testQueue = testQueue test.tasks = [] |