    {:onyx/name :B
     :onyx/ident :core.async/read-from-chan
     :onyx/type :input
+    :onyx/pending-timeout 200000
     :onyx/medium :core.async
     :onyx/batch-size batch-size
     :onyx/max-peers 1

   {:onyx/name :C
    :onyx/ident :core.async/read-from-chan
    :onyx/type :input
    :onyx/medium :core.async
    :onyx/batch-size batch-size
    :onyx/max-peers 1

  [{:onyx/name :A
    :onyx/ident :core.async/read-from-chan
    :onyx/type :input
    :onyx/pending-timeout 200000
    :onyx/medium :core.async
    :onyx/batch-size batch-size
    :onyx/max-peers 1
