text: 
  # -*- coding: utf-8 -*-
  
  """ Cleans up default rq failed-queue.
      Only cleans up jobs from a target queue.
      Useful for experimenting with rq & redis.
      """
  
  import os, pprint
  import redis, rq
  
  
  TARGET_QUEUE = 'usep'
  queue_name = 'failed'
  q = rq.Queue( queue_name, connection=redis.Redis() )
  
  d = { 'jobs': [] }
  failed_count = 0
  for job in q.jobs:
      if not job.origin == TARGET_QUEUE:
          continue
      failed_count += 1
      job_d = {
          '_args': job._args,
          '_kwargs': job._kwargs,
          '_func_name': job._func_name,
          'description': job.description,
          'dt_created': job.created_at,
          'dt_enqueued': job.enqueued_at,
          'dt_ended': job.ended_at,
          'origin': job.origin,
          'id': job._id,
          'traceback': job.exc_info,
          'meta': job.meta,
          '_result': job._result,
          '_status': job._status,
          }
      d['jobs'].append( job_d )
      job.delete()
  d['initial_failed_target_count'] = failed_count
  
  q2 = rq.Queue( queue_name, connection=redis.Redis() )
  d['current_failed_target_count'] = len(q2.jobs)
  
  pprint.pprint( d )
  