                             instance-rpc-chan service-id reason-map start-new-service-fn queue-timeout-ms metric-group))]
       (au/on-chan-close request-state-chan
                         (fn on-request-state-chan-close []
-                          (cid/cdebug correlation-id "request-state-chan closed")
-                          ; assume request did not process successfully if no value in promise
-                          (deliver reservation-status-promise :generic-error)
-                          (let [status @reservation-status-promise]
-                            (cid/cinfo correlation-id "done processing request" status)
-                            (when (= :success status)
-                              (counters/inc! (metrics/service-counter service-id "request-counts" "successful")))
-                            (when (= :generic-error status)
-                              (cid/cerror correlation-id "there was a generic error in processing the request;"
-                                          "if this is a client or server related issue, the code needs to be updated."))
-                            (when (not= :success-async status)
-                              (counters/dec! (metrics/service-counter service-id "request-counts" "outstanding"))
-                              (statsd/gauge-delta! metric-group "request_outstanding" -1))
-                            (service/release-instance-go instance-rpc-chan instance {:status status, :cid correlation-id, :request-id request-id})))
-                        (fn [e] (log/error e "error releasing instance!")))
+                          (cid/with-correlation-id
+                            correlation-id
+                            (log/debug "request-state-chan closed")
+                            ; assume request did not process successfully if no value in promise
+                            (deliver reservation-status-promise :generic-error)
+                            (let [status @reservation-status-promise]
+                              (log/info "done processing request" status)
+                              (when (= :success status)
+                                (counters/inc! (metrics/service-counter service-id "request-counts" "successful")))
+                              (when (= :generic-error status)
+                                (log/error "there was a generic error in processing the request;"
+                                            "if this is a client or server related issue, the code needs to be updated."))
+                              (when (not= :success-async status)
+                                (counters/dec! (metrics/service-counter service-id "request-counts" "outstanding"))
+                                (statsd/gauge-delta! metric-group "request_outstanding" -1))
+                              (service/release-instance-go instance-rpc-chan instance {:status status, :cid correlation-id, :request-id request-id}))))
+                        (fn [e]
+                          (cid/with-correlation-id
+                            correlation-id
+                            (log/error e "error releasing instance!"))))
       instance)))
 
 (defn- handle-response-error

                            :max-queue-length max-queue-length
                            :outstanding-requests outstanding-requests
                            :service-id service-id}]
          (log/info "Max queue length exceeded" response-map)
          (meters/mark! (metrics/service-meter service-id "response-rate" "error" "queue-length"))
          (-> {:details response-map, :message "Max queue length exceeded", :status 503}
              (utils/data->error-response request)))

                              [bytes-streamed false])))
                        (catch Exception e
                          (histograms/update! (metrics/service-histogram service-id "response-size") bytes-streamed)
                          (log/error "error occurred after streaming" bytes-streamed "bytes in response.")
                          ; Handle lower down
                          (throw e)))]
                  (let [bytes-reported-to-statsd'
