You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gump.apache.org by le...@apache.org on 2005/05/01 22:49:35 UTC

svn commit: r165540 - /gump/trunk/python/gump/core/runner/demand.py

Author: leosimons
Date: Sun May  1 13:49:34 2005
New Revision: 165540

URL: http://svn.apache.org/viewcvs?rev=165540&view=rev
Log:
When running gump in offline mode, its possible to get this exception:

 ------ Perform Artifact Repository Search for : cocoon-block-mail
 ------ Extracted (fallback) artifacts from Repository : cocoon-block-mail
Dispatch Event : EntityRunEvent:Project:cocoon-block-mail
Process Project [Project:cocoon-block-mail] using [XDocDocumenter]
Traceback (most recent call last):
  File bin/integrate.py, line 113, in ?
    irun()
  File bin/integrate.py, line 90, in irun
    result = getRunner(run).perform()
  File /x1/gump/public/gump/python/gump/core/runner/runner.py, line 249, in perform
    return self.performRun()
  File /x1/gump/public/gump/python/gump/core/runner/demand.py, line 211, in performRun
    self.waitForThreads()
  File /x1/gump/public/gump/python/gump/core/runner/demand.py, line 73, in waitForThreads
    self.group.waitForAll()
AttributeError: OnDemandRunner instance has no attribute 'group'
Process Exit Code : 1

Checking for the existence of 'group' should fix that.

Modified:
    gump/trunk/python/gump/core/runner/demand.py

Modified: gump/trunk/python/gump/core/runner/demand.py
URL: http://svn.apache.org/viewcvs/gump/trunk/python/gump/core/runner/demand.py?rev=165540&r1=165539&r2=165540&view=diff
==============================================================================
--- gump/trunk/python/gump/core/runner/demand.py (original)
+++ gump/trunk/python/gump/core/runner/demand.py Sun May  1 13:49:34 2005
@@ -70,7 +70,9 @@
         """
         Wait for all workers to complete.
         """
-        self.group.waitForAll()
+        if self.group:
+            if hasattr(self.group, "waitForAll"):
+                self.group.waitForAll()
         
     def performUpdate(self,module):
         """