                       (map (juxt :name :id))
                       (into {}))
 
-        non-input-task-ids (set (vals (dissoc task-ids :in :out)))
+        non-input-task-ids (set (vals (dissoc task-ids :in)))
 
         remove-completed-ch (go-loop []
                                      (let [v (<!! out-chan)]

    :onyx/batch-size batch-size
    :onyx/doc "Writes segments to a core.async channel"}])

(def workflow [[:in :inc] [:inc :out]])

(def chan-size 10000)


      (fact after-done => #{}))

    (close! kill-ch)
    (<!! mess-with-peers-ch)
    (helper-env/remove-n-peers test-env 9))

    (finally 
