anchor.diff:                  workers = 0,
                   batches = 0,
                   orgs_per_batch = 10,
  -                node_batch_size = 20}).
  +                node_batch_size = 20,
  +                orgs_to_migrate}).
   
   start_link(PreloadAmt) ->
       gen_fsm:start_link({local, ?SERVER}, ?MODULE, [PreloadAmt], []).
  
positive.code: log(Level, Fmt, Args) when is_list(Args) ->
      Id = pid_to_list(self()),
      fast_log:Level(mover_manager_log, Id, Fmt, Args).
  
negative.code:                 Count ->
                      BatchesLeft = Batches - 1,
                      log(info, "~B workers ok, ~B batches to go", [Count, BatchesLeft]),
                      State1 = State#state{workers=Count, batches = BatchesLeft,
                                           orgs_to_migrate = OrgsRest},
                      {next_state, running, State1}
              end
      end.
      
  