anchor.diff:  node_status_row_to_record(Row) ->
       #pushy_node_status{org_id = safe_get(<<"org_id">>, Row),
                          node_name = safe_get(<<"node_name">>, Row),
  -                       status = hb_status(safe_get(<<"status">>, Row)),
  +                       status = hb_status_as_atom(safe_get(<<"status">>, Row)),
                          last_updated_by = safe_get(<<"last_updated_by">>, Row),
                          created_at = trunc_date_time_to_second(safe_get(<<"created_at">>, Row)),
                          updated_at = trunc_date_time_to_second(safe_get(<<"updated_at">>, Row))}.
  
positive.code:                                                            {error, term()}.
  %% @doc create an object given a pushy object record
  create_object(#pushy_node_status{status=Status}=NodeStatus) ->
      NodeStatus1 = NodeStatus#pushy_node_status{status=hb_status(Status)},
      create_object(insert_node_status, NodeStatus1);
  %% This does not exactly follow the same pattern as it needs to
  %% insert a list of job_nodes into a separate table.
  
negative.code:                     }.
  
  %% Heartbeat Status translators
  hb_status_as_int(X) when is_integer(X) -> X;
  hb_status_as_int(down) -> 0;
  hb_status_as_int(up) -> 1.
  hb_status_as_atom(X) when is_atom(X) -> X;
  hb_status_as_atom(0) -> down;
  hb_status_as_atom(1) -> up.
  
  %% Job Status translators
  job_status(new) -> 0;
  