@@ -302,12 +302,12 @@ class Channel(object):
302
302
---------------------+
303
303
|
304
304
|
305
- Ch. A W :4,Q:12,R:4 +-----------------------
305
+ Ch. A C :4,Q:12,R:4 +-----------------------
306
306
307
- ---------------------+ Ch. root W :5,Q:0,R:4
307
+ ---------------------+ Ch. root C :5,Q:0,R:4
308
308
|
309
309
---------------------+
310
- Ch. B W :1,Q:0,R:0
310
+ Ch. B C :1,Q:0,R:0
311
311
---------------------+-----------------------
312
312
313
313
The above diagram illustrates two channels joining in the root channel.
@@ -369,7 +369,7 @@ def get_subchannel_by_name(self, subchannel_name):
369
369
return self .children .get (subchannel_name )
370
370
371
371
def __str__ (self ):
372
- return "%s(W :%d,Q:%d,R:%d,F:%d)" % (self .fullname ,
372
+ return "%s(C :%d,Q:%d,R:%d,F:%d)" % (self .fullname ,
373
373
self .capacity ,
374
374
len (self ._queue ),
375
375
len (self ._running ),
@@ -505,7 +505,7 @@ class ChannelManager(object):
505
505
[<ChannelJob B1>, <ChannelJob A1>, <ChannelJob A2>, <ChannelJob A3>]
506
506
507
507
Job A2 is done. Next job to run is A5, even if we have
508
- higher priority job in channel B, because channel B as a capacity of 1.
508
+ higher priority job in channel B, because channel B has a capacity of 1.
509
509
510
510
>>> cm.notify(db, 'A', 'A2', 2, 0, 10, None, 'done')
511
511
>>> pp(list(cm.get_jobs_to_run(now=100)))
0 commit comments