anchor.diff:              {error, Error}
       end.
   
  +-spec fetch_incomplete_jobs() -> {ok, [ #pushy_job{} ] } | {error, term()}.
   fetch_incomplete_jobs() ->
       case sqerl:select(find_incomplete_jobs, []) of
           {ok, none} ->
  
positive.code: %% See the 'find_job_by_id' prepared query for the row "shape".
  job_join_rows_to_record(Rows) ->
      job_join_rows_to_record(Rows, []).
  job_join_rows_to_record([LastRow|[]], JobNodes) ->
      C = proplist_to_job_node(LastRow),
      CreatedAt = safe_get(<<"created_at">>, LastRow),
  
negative.code:                     org_id = safe_get(<<"org_id">>, Node),
                      node_name = safe_get(<<"node_name">>, Node)}.
  
  -spec proplist_to_job_node(Proplist:: proplist()) -> #pushy_job_node{}.
  %% @doc Convenience function for assembling a job_node tuple from a proplist
  proplist_to_job_node(Proplist) ->
      case safe_get(<<"node_name">>, Proplist) of
  