 
 (defn parallel-env-base []
   {::pc/indexes           @pindexes
-   ::pc/resolver-dispatch resolver-fn
+   ::pc/resolver-dispatch resolver-fn-p
    ::pt/trace*            trace
    ::p/entity             (atom {})
    ::pp/key-watchers      (atom {})

   2 "b"
   3 "c"})

(defresolver 'i->l
  {::pc/input  #{:i}
   ::pc/output [:l]
   ::pc/batch? true}

    (fn [_ i-values]
      (mapv #(hash-map :l (get i->l (:i %))) i-values))))

(defresolver-p 'error
  {::pc/output [:error]}
  (fn [_ _]
    (throw (ex-info "Error" {}))))

(defresolver-p 'error-batch
  {::pc/input  #{:i}
   ::pc/output [:error-batch]
   ::pc/batch? true}
  (fn [_ _]
    (throw (ex-info "Error" {}))))

(defresolver-p 'error->d
  {::pc/input  #{:error}
   ::pc/output [:d]}
  (fn [_ _]
    {:d 3}))

(defresolver-p 'invalid
  {::pc/output [:invalid]}
  (fn [_ _]
    42))
