 ;        (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)))
+        (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)))
         )))
;
;
;(defmulti mk-executor-stats executor-selector)
;(defmulti close-component executor-selector)
;
;
;(defn throttled-report-error-fn [executor]

;          [[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]
