         item = results.get_snapshot.Items[0]
         s3_ro_queue.push((c) ->
           s3.get('/'+snapshots_bucket+'/'+item.doc.S+'-'+item.v.N+'.snapshot', 'buffer', c)
-        , cb)
+        , 'query Snapshot('+item.doc.S+'-'+item.v.N+')', cb)
       ]
     (error, results) ->
       if error?

          (item, cb) ->
            s3_rw_queue.push((c) ->
              s3.del('/'+snapshots_bucket+'/'+item.doc.S+'-'+item.v.N+'.snapshot', c)
            , cb)
          (error)->
            if error?
              cb(error, null)

                  Value: { S: item.doc.S }
            operations_rw_queue.push((c) ->
              db.deleteItem(request, c)
            , 'delete Operation('+item.doc.S+'-'+item.v.N+')', cb)
          (error)->
            if error?
              cb(error, null)
