 
         async.forEachSeries(results.list_snapshots.Items,
           (item, cb) ->
+            params =
+              BucketName: snapshots_bucket
+              ObjectName: item.doc.S+'-'+item.v.N+'.snapshot'
+
             s3_rw_queue.push((c) ->
-              s3.del('/'+snapshots_bucket+'/'+item.doc.S+'-'+item.v.N+'.snapshot', c)
+              s3.DeleteObject(params, c)
             , 'delete Snapshot('+item.doc.S+'-'+item.v.N+')', cb)
           (error)->
             if error?

        binaryCompressor.encode(JSON.stringify(docData.snapshot), cb)

      write_data: ['compress_data', (cb, results) ->
        path = snapshots_bucket+'/'+docName+'-'+docData.v+'.snapshot'
        headers = {}

        s3_rw_queue.push((c) ->
          s3.put(path, headers, results.compress_data, c)
        , 'write Snapshot('+docName+'-'+docData.v+')', cb)
      ]
    (error, results) ->

        binaryCompressor.encode(JSON.stringify(docData.snapshot), cb)

      write_data: ['compress_data', (cb, results) ->
        params =
          BucketName: snapshots_bucket
          ObjectName: docName+'-'+docData.v+'.snapshot'
          ContentLength: results.compress_data.length
          Body: results.compress_data

        s3_rw_queue.push((c) ->
          s3.PutObject(params, c)

        , 'write Snapshot('+docName+'-'+docData.v+')', cb)
      ]
    (error, results) ->
