anchor.diff:  respond(<<"run">>, JobId, #state{node_id = NodeId} = State) ->
       State1 = send_response(<<"ack_run">>, JobId, State),
       lager:info("[~s] Wheee ! Running a job...", [NodeId]),
  -    send_response(<<"complete">>, JobId, State1);
  +    send_response(<<"succeeded">>, JobId, State1);
   respond(<<"abort">>, undefined, State) ->
       send_response(<<"aborted">>, null, State);
   respond(<<"abort">>, JobId, State) ->
  
positive.code:                                   node_id = NodeId} = State) ->
      lager:debug("Sending response for ~s : ~s", [NodeId, Type]),
      Msg = {[{node, NodeId},
              {client, ClientName},
              {org, OrgName},
              {type, Type},
              {timestamp, list_to_binary(httpd_util:rfc1123_date())},
  
negative.code: 
      State = #state{command_sock = CommandSock,
                     heartbeat_sock = HeartbeatSock,
                     org_name = OrgName,
                     heartbeat_interval = Interval,
                     sequence = 0,
  