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:             {error, Error}
      end.
  
  fetch_jobs(OrgId) ->
      case sqerl:select(find_jobs_by_org, [OrgId]) of
          {ok, none} ->
  
negative.code: trunc_date_time_to_second({{YY,MM,DD},{H,M,S}}) ->
      {{YY,MM,DD},{H,M, erlang:trunc(S)}}.
  
  -spec job_join_rows_to_record(Rows :: [proplist()]) ->  #pushy_job{}.
  %% @doc Transforms a collection of proplists representing a job / job_nodes join query
  %% result and collapses them all into a single job record. There is a row for each
  %% job_node. A job_node tuple is extracted from each row; job information is extracted
  