 
 (def workflow {:in {:inc :out}})
 
-(def n-jobs 10)
+(def n-jobs 3)
 
 (def n-peers 10)
 

  (testing "All peers got a roughly even number of tasks assigned"
    (su/peer-fairness result-db n-peers n-jobs tasks-per-job)))

(alter-var-root #'system component/stop)

(run-tests 'onyx.coordinator.simulant-test)


(def result-db (d/db (:conn log)))

#_(deftest test-small-cluster-few-jobs
  (testing "No tasks are left incomplete"
    (su/task-completeness result-db))

