thread-transduce.clj

(defn generate-order
  [db taskdefs ref-kw]
  (->> taskdefs
       (map :db/id)
       (workflow/sort-taskdefs db)
       (map (fn [id] (d/entity db id)))
       (map :task.def/id)
       (map (fn [id] [ref-kw id]))))

(defn generate-order*
  [db taskdefs ref-kw]
  (into []
        (comp (map :db/id)
              (fn [ids] (workflow/sort-taskdefs db ids))
              (map (fn [id] (d/entity db id)))
              (map :task.def/id)
              (map (fn [id] [ref-kw id])))
        taskdefs))