anchor.diff:      case {node() == get_gs_client_node(), is_connected()} of
           {true, true} ->
               try
  -                oneprovider:on_connect_to_oz()
  +                run_on_connect_to_oz_procedures()
               catch
                   % Connection was lost in meantime. Ignore it as `on_connect_to_oz`
                   % will be called when connection is established again.
  
positive.code:     consistent_hashing:get_assigned_node(?GS_CLIENT_WORKER_GLOBAL_NAME).
  
  
  -spec start_gs_client_worker() -> alive | error.
  start_gs_client_worker() ->
      case supervisor:start_child(?GS_WORKER_SUP, gs_client_worker_spec()) of
          {ok, _} ->
              try
                  case node_manager:get_cluster_status() of
                      {error, cluster_not_ready} -> ok;
                      {ok, _} ->
                          ?info("Running on-connect procedures"),
                          oneprovider:on_connect_to_oz()
                  end,
                  alive
              catch Type:Reason ->
  
negative.code:     end.
  
  
  %% @private
  -spec run_on_connect_to_oz_procedures() -> ok.
  run_on_connect_to_oz_procedures() ->
      ?info("Executing on-connect-to-oz procedures..."),
      oneprovider:on_connect_to_oz(),
      ?info("Successfully executed on-connect-to-oz procedures").
  
  
  %% @private
  -spec gs_client_worker_spec() -> supervisor:child_spec().
  gs_client_worker_spec() -> #{
      id => ?GS_CLIENT_WORKER_GLOBAL_NAME,
  