|
|
@ -23,6 +23,16 @@ def get_scale(x):
|
|
|
|
return scale
|
|
|
|
return scale
|
|
|
|
return x
|
|
|
|
return x
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def state_symbol(state):
|
|
|
|
|
|
|
|
symbols = {
|
|
|
|
|
|
|
|
'busy': red(u'\u25CF'),
|
|
|
|
|
|
|
|
'idle': green(u'\u25CB'),
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
|
|
|
return symbols[state]
|
|
|
|
|
|
|
|
except KeyError:
|
|
|
|
|
|
|
|
return state
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def parse_args():
|
|
|
|
def parse_args():
|
|
|
|
parser = optparse.OptionParser()
|
|
|
|
parser = optparse.OptionParser()
|
|
|
@ -85,16 +95,6 @@ def show_queues(opts, args, parser):
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
break
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
def state_symbol(state):
|
|
|
|
|
|
|
|
symbols = {
|
|
|
|
|
|
|
|
'busy': red(u'\u25CF'),
|
|
|
|
|
|
|
|
'idle': green(u'\u25CB'),
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
|
|
|
return symbols[state]
|
|
|
|
|
|
|
|
except KeyError:
|
|
|
|
|
|
|
|
return state
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def show_workers(opts, args, parser):
|
|
|
|
def show_workers(opts, args, parser):
|
|
|
|
while True:
|
|
|
|
while True:
|
|
|
|
qs = Queue.all()
|
|
|
|
qs = Queue.all()
|
|
|
|