           ))
 
       (^ByteBuffer downloadChunk [this ^String id]
+        (ensure-leadership leader-elections)
         (let [downloaders (:downloaders nimbus)
               ^BufferInputStream is (.get downloaders id)]
           (when-not is

          ))

      (^void finishFileUpload [this ^String location]
        (let [uploaders (:uploaders nimbus)
              ^WritableByteChannel channel (.get uploaders location)]
          (when-not channel

      (^void submitTopologyWithOpts
        [this ^String storm-name ^String uploadedJarLocation ^String serializedConf ^StormTopology topology
         ^SubmitOptions submitOptions]
        (ensure-leadership leader-elections)
        (try
          (assert (not-nil? submitOptions))
          (validate-topology-name! storm-name)
