anchor.diff:  handle_sync_event(_Event, _From, StateName, Job) ->
       {reply, ok, StateName, Job}.
   
  -handle_info(execute, executing, Job) ->
  -    error_logger:info_msg("JOB STATUS EXECUTING~n"),
  -    {next_state, executing, save_job_status(executing, Job)};
  -handle_info(executing, new, Job) ->
  -    error_logger:info_msg("JOB STATUS EXECUTING~n"),
  -    {next_state, executing, save_job_status(executing, Job)};
   handle_info(error, executing, Job) ->
       error_logger:info_msg("JOB STATUS ERROR~n"),
       {next_state, error, save_job_status(error, Job)};
  
positive.code:             %% TODO compute timeout based on existing created_at
              erlang:send_after(Duration*1000, self(), expired),
              error_logger:info_msg("Beginning execution of job ~s~n", [JobId]),
              execute(JobId),
              {next_state, executing, Job};
          false ->
              error_logger:error_msg("Failed to register job tracker process ~p for ~p~n", [JobId, self()]),
              {stop, shutdown, Job}
  
negative.code: -export([start_link/1]).
  
  -export([load_from_db/2,
           register_process/2]).
  
  -include_lib("pushy_sql.hrl").
  
  