                session
                target-entity
                fk
-               fk-val)]
+               fk-val
+               opts)]
 
       (return deferred-context trs))))
 

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


                                     source-entity
                                     target-entity
                                     source-record
                                     denorm-rel
                                     (select-keys opts [:fetch-size]))

           ;; a (hopefully empty) stream of any errors from denormalization
           :let [trerrs (->> trs
