   (shutdown-all-workers [this])
   )
 
-(defn- assignments-snapshot [storm-cluster-state callback existing-assignment assignment-versions]
-  (log-message (str "Recalculating assignments with old: " assignment-versions))
+(defn- assignments-snapshot [storm-cluster-state callback assignment-versions]
   (let [storm-ids (.assignments storm-cluster-state callback)]
     (let [new-assignments 
           (->>
            (dofor [sid storm-ids] 
                   (let [recorded-version (:version (get assignment-versions sid))]
                     (if-let [assignment-version (.assignment-version storm-cluster-state sid callback)]
-                      (do
-                        (log-message (str "Version: " assignment-version " || Recorded Version: " recorded-version))
-                        (if (= assignment-version recorded-version)
-                          (do
-                            (log-message "Using Existing assignment.")
-                            {sid (get assignment-versions sid)})
-                          (do
-                            (log-message "Getting new Assignments.")
-                            (let [assignments (.assignment-info-with-version storm-cluster-state sid callback)] 
-                              (log-message (str "Assignments: " assignments))
-                              {sid assignments}))))
+                      (if (= assignment-version recorded-version)
+                        {sid (get assignment-versions sid)}
+                        {sid (.assignment-info-with-version storm-cluster-state sid callback)})
                       {sid nil})))
            (apply merge)
            (filter-val not-nil?))]
-
+          
       {:assignments (into {} (for [[k v] new-assignments] [k (:data v)]))
        :versions new-assignments})))
-            
   
 (defn- read-my-executors [assignments-snapshot storm-id assignment-id]
   (let [assignment (get assignments-snapshot storm-id)

                           (:assignment-id supervisor))
          new-assignment (->> all-assignment
                              (filter-key #(.confirmAssigned isupervisor %)))
          assigned-storm-ids (assigned-storm-ids-from-port-assignments new-assignment)]
      (log-debug "Synchronizing supervisor")
      (log-debug "Storm code map: " storm-code-map)
      (log-debug "Downloaded storm ids: " downloaded-storm-ids)

          ^ISupervisor isupervisor (:isupervisor supervisor)
          ^LocalState local-state (:local-state supervisor)
          sync-callback (fn [& ignored] (.add event-manager this))
          assignment-versions (.get local-state LS-ASSIGNMENT-VERSIONS)
          {assignments-snapshot :assignments versions :versions}  (assignments-snapshot 
                                                                   storm-cluster-state sync-callback 
                                                                   assignment-versions)
          storm-code-map (read-storm-code-locations assignments-snapshot)
          downloaded-storm-ids (set (read-downloaded-storm-ids conf))
          all-assignment (read-assignments
