                      (and
                        (not (nil? in-data))
                        (not (.endsWith scenario "-direct"))
-                       (not (.endsWith scenario "-pmap")))
+                       (not (.endsWith scenario "-pmap"))
+                       (not (.contains scenario "async-pipeline")))
                      (create-local-processing-pipeline
                        @proc-fns
                        (fn [_ _]

        1000)
      (run-once
        (executor)
        (fn [] (System/exit 0)) 120000))))


                                (async/>!! in-chan data)))))
                      (and
                        (not (nil? in-data))
                        (not (nil? pipeline))
                        (> batch-delay 0)
                        (> batch-size 0)) (create-batched-in-fn (get-in-fn pipeline))
                      (and
                        (not (nil? in-data))
                        (not (nil? pipeline))) (create-flood-in-fn (get-in-fn pipeline))
                      :default (if (not (.contains scenario "async-pipeline"))
                                 (fn [] (.inc out-cntr)))))
          async-out-count-loop (if
                                 (and
                                   (.endsWith scenario "-async-pipeline")
