diff options
| author | Sebastian Thiel <byronimo@gmail.com> | 2010-06-09 10:34:12 +0200 |
|---|---|---|
| committer | Sebastian Thiel <byronimo@gmail.com> | 2010-06-09 10:34:12 +0200 |
| commit | 15941ca090a2c3c987324fc911bbc6f89e941c47 (patch) | |
| tree | 3c508eb2e8be484e8685cddaa1de72826fbf9302 /lib/git/async/task.py | |
| parent | f78d4a28f307a9d7943a06be9f919304c25ac2d9 (diff) | |
| download | gitpython-15941ca090a2c3c987324fc911bbc6f89e941c47.tar.gz | |
queue: fixed critical bug in the notify method, as it was not at all thread-safe, causing locks to be released multiple times. Now it runs very fast, and very stable apparently.
Now its about putting previous features back in, and studying their results, before more complex task graphs can be examined
Diffstat (limited to 'lib/git/async/task.py')
| -rw-r--r-- | lib/git/async/task.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/lib/git/async/task.py b/lib/git/async/task.py index f9536a45..f1448f96 100644 --- a/lib/git/async/task.py +++ b/lib/git/async/task.py @@ -89,7 +89,6 @@ class OutputChannelTask(Node): def process(self, count=0): """Process count items and send the result individually to the output channel""" items = self._read(count) - # print "task read", len(items) try: # increase the ref-count - we use this to determine whether anyone else # is currently handling our output channel. As this method runs asynchronously, @@ -119,7 +118,7 @@ class OutputChannelTask(Node): # END handle single apply except Exception, e: self._exc = e - print "task error:", str(e) # TODO: REMOVE DEBUG, or make it use logging + print >> sys.stderr, "task error:", str(e) # TODO: REMOVE DEBUG, or make it use logging self.set_done() # unschedule all, we don't know how many have been produced actually # but only if we don't apply single please |