anchor.diff:                      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
  
positive.code:           end,
     lists:filter(Pred,CbFields).
  
  %% @doc Inserts job_nodes records into the database. All records are timestamped
  %% with the same stamp, namely `CreatedAt`, which is a binary string in SQL date time
  %% format.
  
negative.code:             {error, Error}
      end.
  
  -spec create_job(#pushy_job{}) -> {ok, 1} | {error, term()}.
  create_job(#pushy_job{status = Status, job_nodes = JobNodes}=Job) ->
      %% convert status into an integer
      Job1 = Job#pushy_job{status=Status},
  