diff --git a/lib/taps/data_stream.rb b/lib/taps/data_stream.rb
index <HASH>..<HASH> 100644
--- a/lib/taps/data_stream.rb
+++ b/lib/taps/data_stream.rb
@@ -167,7 +167,7 @@ class DataStream
     log.debug "DataStream#fetch_from_resource state -> #{state.inspect}"
     state[:chunksize] = Taps::Utils.calculate_chunksize(state[:chunksize]) do |c|
       state[:chunksize] = c.to_i
-      res = resource.post({:state => OkJson.encode(self)}, headers)
+      res = resource.post({:state => OkJson.encode(self.to_hash)}, headers)
     end
 
     begin
need to encode self.to_hash specifically