anchor.diff:      lager:info("Job ~p -> running", [Job#pushy_job.id]),
       Job2 = Job#pushy_job{status = running},
       State2 = State#state{job = Job2},
  +    pushy_object:update_object(update_job, Job2, Job2#pushy_job.id),
       send_command_to_all(<<"run">>, State2),
       maybe_finished_running(State2).
   
  
positive.code:     lager:info("Job ~p -> voting", [Job#pushy_job.id]),
      Job2 = Job#pushy_job{status = voting},
      State2 = State#state{job = Job2},
      send_command_to_all(<<"commit">>, State2),
      {next_state, StateName, State3} = maybe_finished_voting(State2),
      {ok, StateName, State3}.
  
negative.code:     {'stop', 'shutdown', #state{}}.
  init(#pushy_job{id = JobId, job_nodes = JobNodeList} = Job) ->
      Host = pushy_util:get_env(pushy, server_name, fun is_list/1),
      pushy_object:create_object(create_job, Job, JobId),
      case pushy_job_state_sup:register_process(JobId) of
          true ->
              JobNodes = dict:from_list([{{OrgId, NodeName}, JobNode} ||
  