anchor.diff:              State = add_start_event(State0, Job#pushy_job.command, Job#pushy_job.run_timeout, Job#pushy_job.quorum, NodeCount, Requestor),
               listen_for_down_nodes(dict:fetch_keys(JobNodes)),
   
  -            lager:debug([{job_id,Job#pushy_job.id}],
  +            lager:info([{job_id,Job#pushy_job.id}],
                           "Job ~p starting '~p' on ~p nodes, with timeout ~ps",
                           [JobId, Job#pushy_job.command, length(JobNodeList), Job#pushy_job.run_timeout]),
   
  
positive.code:     {Done, lists:reverse(RevEvs)}.
  
  add_event(State = #state{next_event_id = Id, rev_events = RevEvents}, EventName, PropList) ->
      IdStr = iolist_to_binary(io_lib:format("job-~B", [Id])), 
      Ev = pushy_event:make_event(EventName, IdStr, PropList),
      JobId = State#state.job#pushy_job.id,
      post_to_subscribers(State, {job_ev, JobId, Ev}),
  
negative.code:                     State1 = add_run_start_event(State, NodeName),
                      set_node_state(NodeRef, running, State1);
          running  -> State;
          terminal ->
                      State1 = add_run_complete_event(State, NodeName, client_died_while_running),
                      send_to_rehab(NodeRef, State1)
      end,
  