         (cond
           (#{"phase-0" "phase-0b" "phase-0c" "phase-0d"} phase)
           (pg/future+
-            (run-phase-0 eid recipient get-toolinfo template))
+            (run-phase-0 eid recipient get-toolinfo template status))
 
           (#{"phase-1" "bt2-phase-1" "bt1-phase-1" "star-phase-1"} phase)
           (pg/future+
-            (run-phase-1 eid recipient get-toolinfo template :repk rep))
+            (run-phase-1 eid recipient get-toolinfo template status :repk rep))
 
           (#{"phase-2" "phase-2b"} phase)
           (run-phase-2 exp eid recipient get-toolinfo template)

                       (mapcat #((get-exp-info eid :replicate-names) %)
                               (get-exp-info eid :sample-names))
                       sample-names)]
    (doseq [tuple (partition-all 2 sample-names)]
      (let [futs-vecs
            (mapv
             (fn[snm]
               (let [job (assoc-in phase1-job-template [:nodes :ph1 :args]
                                   (get-phase-1-args
                                    exp eid snm :repk repk
                                    :bowtie bt :star star))
                     cfg (-> job
                             (pg/config-pgm-graph-nodes get-toolinfo nil nil)
                             pg/config-pgm-graph)]
                 #_(clojure.pprint/pprint cfg)
                 (->> cfg pg/make-flow-graph pg/run-flow-program)))
             tuple)]
        (mapv (fn[futs] (mapv (fn[fut] (deref fut)) futs))
              futs-vecs)))
    (pg/send-msg
     [recipient]
     (str "Aerobio job status: " exp " phase-1  " eid)
     (str "Finished " (if repk "replicates" "merged") " for " eid ))))


;;;(ns-unmap 'aerobio.htseq.common 'get-comparison-files)
(defmulti



(defn launch-action
  [eid recipient get-toolinfo template & {:keys [action rep compfile status]}]
  (prn "LAUNCH: "
       [eid recipient template action rep compfile])
  (let [exp (get-exp-info eid :exp)]
