anchor.diff:      NodeDocs = chef_otto:bulk_get(S, OrgDb, NodeCouchIds),
       NodeMeta = [ fetch_node_meta_data(S, OrgName, OrgId, Name, Id)
                    || {Name, Id} <- NodeBatch ],
  -    write_nodes_to_sql(OrgId, lists:zip(NodeMeta, NodeDocs)),
  +    Ctx = chef_db:make_context(<<"my-req-id-for-mover">>, S),
  +    write_nodes_to_sql(Ctx, OrgId, lists:zip(NodeMeta, NodeDocs)),
       {next_state, migrate_nodes,
        State#state{node_list = safe_split(BatchSize, NodeList)}, 0}.
   
  
positive.code: %% Internal Function Definitions
  %% ------------------------------------------------------------------
  
  write_nodes_to_sql(OrgId, [{#node_cache{}=MetaData, NodeData} | Rest]) ->
      #node_cache{name = Name, authz_id = AuthzId,
                  id = OrigId,
                  requestor_id = RequestorId} = MetaData,
  
negative.code: migrate(Pid) ->
      gen_fsm:send_event(Pid, go).
  
  %% {S, Config} = node_mover:setup().
  %% {ok, Pid} = node_mover_worker:start_link(Config).
  %% node_mover_worker:migrate(Pid).
  