                     clojurify-structure)]
     (merge storm-conf (apply dissoc spec-conf to-remove))
     ))
-
-
-(defn executor-selector [executor-data & _] (:type executor-data))
-(defmulti mk-threads executor-selector)
 
 
 (defn- tuple-execute-time-delta!

;        (doseq [user-context (map :user-context (vals task-datas))]
;          (doseq [hook (.getHooks user-context)]
;            (.cleanup hook)))
;        (when @(:open-or-prepare-was-called? executor-data)
;          (doseq [obj (map :object (vals task-datas))]
;            (close-component executor-data obj)))
        (log-message "Shut down executor " component-id ":" (pr-str executor-id)))
        )))
;          [[nil (TupleImpl. worker-context [interval] Constants/SYSTEM_TASK_ID Constants/METRICS_TICK_STREAM_ID)]]))))))
;
;
;
;;; TODO: refactor this to be part of an executor-specific map
;(defmethod mk-executor-stats :spout [_ rate]
