 ;; Job code
 
 (defn add-path [job-id task-id {:keys [n] :as segment}]
-  ;(when-not (:state-output? segment) (println "New segment " (update segment :path conj [job-id task-id])))
   (update segment :path conj [job-id task-id]))
 
 (def add-paths-calls

    (prop-is (= (set expected-outputs) (set flow-outputs)) "messenger flow values incorrect")
    ;(println "Expected: " expected-outputs)
    ;(println "Outputs:" actual-outputs)
    #_(check-outputs-in-order! peer-outputs)))

(defspec deterministic-abs-test {;:seed X 
                                 :num-tests (times 200)}

      ;          (m/replica-version (:messenger (:state event)))
      ;          (m/epoch (:messenger (:state event)))
      ;          (:job-id event) extent-state)
      (swap! state-atom assoc [(:job-id event) (:slot-id event)] extent-state))))

(defn simple-job-def [job-id]
  (let [n-messages 200
