anchor.diff:      case sqerl:select(find_job_by_id, [JobId]) of
           {ok, Rows} when is_list(Rows) ->
               {ok, job_join_rows_to_record(Rows)};
  +        {ok, none} ->
  +            {ok, not_found};
  +        {error, Error} ->
  +            {error, Error}
  +    end.
  +
  +fetch_jobs(OrgId) ->
  +    case sqerl:select(find_jobs_by_org, [OrgId]) of
  +        {ok, Rows} when is_list(Rows) ->
  +            {ok, prepare_jobs(Rows)};
           {ok, none} ->
               {ok, not_found};
           {error, Error} ->
  
positive.code: 
  -spec job_fields_for_insert(CbFields:: list()) -> list().
  job_fields_for_insert(CbFields) ->
     %% We drop the last record field - job_nodes
     Pred = fun(Elem) ->
             not(is_list(Elem))
            end,
  
negative.code:          update_node_status/1,
           %% job ops
           fetch_job/1,
           fetch_jobs/1,
           create_job/1,
           update_job/1,
           update_job_node/1,
  