anchor.diff:  -define(RTRANSFER_RUNNING_JOBS, rtransfer_running_jobs).
   -define(aggregators_map, aggregators_map).
   -define(gateways_map, gateways_map).
  +-define(rtransfer_tab, rtransfer_tab).
   
   -export([init/1, handle/2, cleanup/0]).
   
  
positive.code: %% @see worker_plugin_behaviour
  -spec init(Args :: term()) -> ok | {error, Error :: any()}.
  init(_Args) ->
      ets:new(rtransfer, [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)})
          end),
  
      ok.
  
negative.code:     {ok, GwPort} = application:get_env(?APP_Name, gateway_listener_port),
  
      URLs =
          case ets:lookup(?rtransfer_tab, {provider_addr_cache, ProviderId}) of
              [{_, ProviderURLs}] -> ProviderURLs;
              [] ->
                  {ok, ProviderDetails} = gr_providers:get_details(provider, ProviderId),
  