Skip to content

Commit

Permalink
Merge pull request #98 from guewen/none-capacity-error
Browse files Browse the repository at this point in the history
A None capacity means infinite. Fix logging error
  • Loading branch information
pedrobaeza committed Jul 30, 2015
2 parents c6e5a9d + 9a42feb commit 14569c7
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions connector/jobrunner/channels.py
Original file line number Diff line number Diff line change
Expand Up @@ -369,8 +369,9 @@ def get_subchannel_by_name(self, subchannel_name):
return self.children.get(subchannel_name)

def __str__(self):
return "%s(C:%d,Q:%d,R:%d,F:%d)" % (self.fullname,
self.capacity,
capacity = u'∞' if self.capacity is None else str(self.capacity)
return "%s(C:%s,Q:%d,R:%d,F:%d)" % (self.fullname,
capacity,
len(self._queue),
len(self._running),
len(self._failed))
Expand Down

0 comments on commit 14569c7

Please sign in to comment.