anchor.diff:      #pushy_job{id = safe_get(<<"id">>, LastRow),
                     org_id = safe_get(<<"org_id">>, LastRow),
                     command = safe_get(<<"command">>, LastRow),
  -                  status = job_status_atom(safe_get(<<"status">>, LastRow)),
  +                  status = job_status(safe_get(<<"status">>, LastRow)),
                     duration = safe_get(<<"duration">>, LastRow),
                     last_updated_by = safe_get(<<"last_updated_by">>, LastRow),
                     created_at = safe_get(<<"created_at">>, LastRow),
  
positive.code: insert_job_nodes([], _OrgId, _JobId, _CreatedAt, _UpdatedAt) ->
      ok;
  insert_job_nodes([{NodeName, Status, _CreatedAt, _UpdatedAt}|Rest], OrgId, JobId, CreatedAt, UpdatedAt) ->
      case sqerl:statement(insert_job_node, [OrgId, NodeName, job_status_code(Status),
            CreatedAt, UpdatedAt, JobId], count) of
          {ok, 1} ->
              insert_job_nodes(Rest, OrgId, JobId, CreatedAt, UpdatedAt);
  
negative.code:                                       updated_at = UpdatedAt,
                                        node_name = NodeName,
                                        org_id = OrgId}) ->
      UpdateFields = [hb_status(Status), LastUpdatedBy, UpdatedAt, OrgId, NodeName],
      do_update(update_node_status_by_orgid_name, UpdateFields).
  
  %% job ops
  