Merge pull request #977 from harrykao/multiprocess_loader

Use a new test loader for each queue item.
nose-devs · Dec 23, 2015 · 344a215 · 344a215
2 parents 0f592c4 + 02f7d84
commit 344a215
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 batch(result):
             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 = []