 ;          [[nil (TupleImpl. worker-context [interval] Constants/SYSTEM_TASK_ID Constants/METRICS_TICK_STREAM_ID)]]))))))
 ;
 ;
-;(defmethod close-component :spout [executor-data spout]
-;  (.close spout))
-;
-;(defmethod close-component :bolt [executor-data bolt]
-;  (.cleanup bolt))
 ;
 ;;; TODO: refactor this to be part of an executor-specific map
 ;(defmethod mk-executor-stats :spout [_ rate]

                    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!

;
;
;(defmulti mk-executor-stats executor-selector)
;
;
;(defn throttled-report-error-fn [executor]
