                  inputs))
           (build-paths job)))
 
-(defn prop-is [ok? & [message]]
-  (when-not ok? 
-    (throw (Exception. message))))
+(defn prop-is [pass? & messages]
+  (when-not pass? 
+    (throw (Exception. (pr-str messages)))))
 
 (defn check-outputs-in-order! 
   "Check that all messages arrive in order, absent rewinds
    This is only true if there is only one peer per task
    at any given time"
   [peer-outputs]
+  (def pppp peer-outputs)
   (doseq [peer-output peer-outputs]
     (doseq [run (->> peer-output
                      (partition-by #(= [:reset-messenger] %))

;; 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

                                                    [500 g/play-group-commands-gen]
                                                    [500 g/write-outbox-entries-gen]
                                                    [500 g/apply-log-entries-gen]]) 
                                    5000))))]
           (let [generated {:phases phases 
                            :uuid-seed uuid-seed}]
             (spit "/tmp/testcase.edn" (pr-str generated))
