 
         s3_rw_queue.push((c) ->
           s3.put(path, headers, data, c)
-        , cb)
+        , 'write Snapshot('+docName+'-'+docData.v+')', cb)
     (error, results) ->
       if error?
         if error.message? and error.message.match 'The conditional request failed'

      task(callback)
    , concurrency)

  push: (fn, callback) =>
    start = new Date().getTime()
    @queue.push(fn, (error, results) =>
      if @timing
        elapsed = new Date().getTime() - start
        capacity = results.ConsumedCapacityUnits if results?
        console.log('Dynamo['+elapsed+'ms,'+capacity+'] '+@name)

      callback(error, results)
    )

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