    source-entity :- Entity
    target-entity :- Entity
    source-record :- t/RecordSchema
-   denorm-rel :- t/DenormalizationRelationshipSchema]
+   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)]
 

                                     source-entity
                                     target-entity
                                     source-record
                                     denorm-rel)

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

               session
               target-entity
               fk
               fk-val
               opts)]

      (return deferred-context trs))))

