lib/mosql/streamer.rb in mosql-0.4.2 vs lib/mosql/streamer.rb in mosql-0.4.3

@@ -239,10 +239,10 @@
           primary_sql_keys = @schema.primary_sql_key_for_ns(ns)
           schema = @schema.find_ns!(ns)
           keys = {}
           primary_sql_keys.each do |key|
             source =  schema[:columns].find {|c| c[:name] == key }[:source]
-            keys[key] = selector[source]
+            keys[source] = selector[source]
           end
 
           log.debug("upsert #{ns}: #{keys}")
 
           update = keys.merge(update)