       ]
 
       meta: ['compressor', (cb, results) ->
-        results.compressor.text.decode(results.get_snapshot.Items[0].meta.S, cb)
+        results.compressor.text.decode(results.get_snapshot.Body.Items[0].meta.S, cb)
       ]
     (error, results) ->
       if error?
         if error == 'Document does not exist'
           callback?(error)
         else if results? and results.get_snapshot?
-          item = results.get_snapshot.Items[0]
+          item = results.get_snapshot.Body.Items[0]
           console.error('Failed to get snapshot data for Document('+item.doc.S+'-'+item.v.N+'): '+util.inspect(error))
           callback?('Failed to get snapshot data')
         else
           console.error('Failed to get snapshot metadata for Document('+docName+'): '+util.inspect(error))
           callback?('Failed to get snapshot metadata')
       else
-        item = results.get_snapshot.Items[0]
+        item = results.get_snapshot.Body.Items[0]
 
         try
           snapshot = JSON.parse(results.snapshot)


      compressor: ['get_snapshot', 'get_data', (cb, results) ->
        cb(null,
          text: new TextCompressor(results.get_snapshot.Items[0].c, options['timing'])
          binary: new BinaryCompressor(results.get_snapshot.Items[0].c, options['timing'])
        )
      ]


        callback?('Failed to fetch operations')
      else
        data = []
        async.map(results.get_metadata.Body.Items, (operation, cb) ->
          compressor = new TextCompressor(operation.c?, options['timing'])
          async.auto(
            snapshot: (c) ->
