anchor.diff:  %% @see worker_plugin_behaviour
   -spec init(Args :: term()) -> ok | {error, Error :: any()}.
   init(_Args) ->
  -    ets:new(rtransfer, [public, named_table, {read_concurrency, true}]),
  +    ets:new(?rtransfer_tab, [public, named_table, {read_concurrency, true}]),
       {ok, _} = rt_map:new({local, ?aggregators_map}),
       {ok, _} = rt_map:new({local, ?gateways_map}),
   
       spawn(
           fun() ->
  -            Nodes = gen_server:call({global, central_cluster_manager}, get_nodes),
  -            ets:insert(rtransfer, {nodes, array:from_list(Nodes)})
  +            try
  +                Nodes = gen_server:call({global, central_cluster_manager}, get_nodes),
  +                ets:insert(?rtransfer_tab, {nodes, array:from_list(Nodes)})
  +            catch
  +                Error:Reason ->
  +                    ?error_stacktrace("~p:~p Failed to fetch nodes list from CCM: ~p:~p",
  +                        [?MODULE, ?LINE, Error, Reason])
  +            end
           end),
   
       ok.
  
positive.code: -define(RTRANSFER_RUNNING_JOBS, rtransfer_running_jobs).
  -define(aggregators_map, aggregators_map).
  -define(gateways_map, gateways_map).
  
  -export([init/1, handle/2, cleanup/0]).
  
  
negative.code:                             fun(URL) -> inet:parse_address(utils:ensure_list(URL)) end,
                              ProviderDetails#provider_details.urls)),
  
                  ets:insert(?rtransfer_tab, {{provider_addr_cache, ProviderId}, ProviderURLs}),
                  ProviderURLs
          end,
  
  