projects
/
gonvert
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Pulling in latest skeleton changes
[gonvert]
/
src
/
util
/
go_utils.py
diff --git
a/src/util/go_utils.py
b/src/util/go_utils.py
index
d066542
..
97d671c
100644
(file)
--- a/
src/util/go_utils.py
+++ b/
src/util/go_utils.py
@@
-191,7
+191,7
@@
class AsyncPool(object):
result = func(*args, **kwds)
isError = False
except Exception, e:
result = func(*args, **kwds)
isError = False
except Exception, e:
- _moduleLogger.error("Error, passing it back to the main thread")
+ _moduleLogger.exception("Error, passing it back to the main thread")
result = e
isError = True
self.__workQueue.task_done()
result = e
isError = True
self.__workQueue.task_done()
@@
-221,7
+221,7
@@
class AsyncLinearExecution(object):
@misc.log_exception(_moduleLogger)
def on_success(self, result):
@misc.log_exception(_moduleLogger)
def on_success(self, result):
- _moduleLogger.debug("Processing success for: %r", self._func)
+ #_moduleLogger.debug("Processing success for: %r", self._func)
try:
trampoline, args, kwds = self._run.send(result)
except StopIteration, e:
try:
trampoline, args, kwds = self._run.send(result)
except StopIteration, e:
@@
-237,7
+237,7
@@
class AsyncLinearExecution(object):
@misc.log_exception(_moduleLogger)
def on_error(self, error):
@misc.log_exception(_moduleLogger)
def on_error(self, error):
- _moduleLogger.debug("Processing error for: %r", self._func)
+ #_moduleLogger.debug("Processing error for: %r", self._func)
try:
trampoline, args, kwds = self._run.throw(error)
except StopIteration, e:
try:
trampoline, args, kwds = self._run.throw(error)
except StopIteration, e: