Merge branch 'delete_all'

Author: Matt George

resweb/server.py

@@ -15,6 +15,7 @@
     Delayed,
     DelayedTimestamp
 )
+from base64 import b64decode
 
 HOST = ResQ("localhost:6379")
 MY_ROOT = os.path.join(os.path.dirname(__file__), 'media')
@@ -45,8 +46,6 @@ def failed(request):
 
 @post('/failed/retry/')
 def failed_retry(request):
-    from base64 import b64decode
-    from pyres import failure
     try:
         import json
     except ImportError:
@@ -59,8 +58,6 @@ def failed_retry(request):
 
 @post('/failed/delete/')
 def failed_delete(request):
-    from base64 import b64decode
-    from pyres import failure
     try:
         import json
     except ImportError:
@@ -70,6 +67,22 @@ def failed_delete(request):
     failure.delete(HOST, job)
     raise Redirect('/failed/')
 
+@get('/failed/delete_all/')
+def delete_all_failed(request):
+     #move resque:failed to resque:failed-staging
+     HOST.redis.rename('resque:failed','resque:failed-staging')
+     HOST.redis.delete('resque:failed-staging')
+     raise Redirect('/failed/')
+
+
+@get('/failed/retry_all')
+def retry_failed(request, number=5000):
+    failures = failure.all(HOST, 0, number)
+    for f in failures:
+        j = b64decode(f['redis_value'])
+        failure.retry(HOST, f['queue'], j)
+    raise Redirect('/failed/')
+
 @get('/workers/(?P<worker_id>\w.+)/')
 def worker(request, worker_id):
     return str(Worker(HOST, worker_id).render())

resweb/templates/failed.mustache

@@ -6,8 +6,20 @@ $(document).ready(function(){
         return false;
     });
 });
+function retry_all(){
+    if(confirm('Are you sure you want to retry all?')){
+        window.location.href = '/failed/retry_all/';
+    }
+}
+function delete_all(){
+    if(confirm('Are you sure you want to delete all?')){
+        window.location.href = '/failed/delete_all';
+    }
+
+}
 </script>
 <h1>Failed Jobs</h1>
+<div class="buttons"><button onclick='retry_all()'>retry all</button> <button onclick='delete_all()'>delete all</button></div>
 <p class='sub'>Showing {{start}} to {{end}} of <b>{{size}}</b> jobs</p>
 <ul class='pagination'>
 {{#pagination}}