                                      source-entity
                                      target-entity
                                      source-record
-                                     denorm-rel)
+                                     denorm-rel
+                                     (select-keys opts [:fetch-size]))
 
            ;; a (hopefully empty) stream of any errors from denormalization
            :let [trerrs (->> trs

               session
               target-entity
               fk
               fk-val)]

      (return deferred-context trs))))


   source-entity :- Entity
   target-entity :- Entity
   source-record :- t/RecordSchema
   denorm-rel :- t/DenormalizationRelationshipSchema
   opts :- r/SelectBufferedOptsSchema]
  (with-context deferred-context
    (mlet [:let [[fk fk-val] (foreign-key-val source-entity source-record denorm-rel)]

