clear_tube.py

clear_tube.py

#!/usr/bin/env python
import sys
import beanstalkc
b = beanstalkc.Connection()
b.watch('deadtraffic')
stats = b.stats_tube('deadtraffic')
ready = stats.get('current-jobs-ready')
for x in range(0, ready):
    sys.stdout.write('\rClearing {} of {}'.format(x, ready))
    sys.stdout.flush()
    j = b.reserve(timeout=0)
    if j is None:
        break
    j.delete()