diff options
| author | Sebastian Thiel <byronimo@gmail.com> | 2010-06-08 16:47:48 +0200 |
|---|---|---|
| committer | Sebastian Thiel <byronimo@gmail.com> | 2010-06-08 16:47:48 +0200 |
| commit | 619c11787742ce00a0ee8f841cec075897873c79 (patch) | |
| tree | 7cfcc718c049b26abedf280bebb6c65a6d6f619c /lib/git/async/task.py | |
| parent | 53152a824f5186452504f0b68306d10ebebee416 (diff) | |
| download | gitpython-619c11787742ce00a0ee8f841cec075897873c79.tar.gz | |
Its getting better already - intermediate commit before further chaning the task class
Diffstat (limited to 'lib/git/async/task.py')
| -rw-r--r-- | lib/git/async/task.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/git/async/task.py b/lib/git/async/task.py index ce701c86..97521cae 100644 --- a/lib/git/async/task.py +++ b/lib/git/async/task.py @@ -88,6 +88,7 @@ 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, @@ -117,6 +118,7 @@ class OutputChannelTask(Node): # END handle single apply except Exception, e: self._exc = e + print 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 |