anchor.diff:  %% ===================================================================
   
   -module(central_logger_test_SUITE).
  --include("test_utils.hrl").
  +-include("nodes_manager.hrl").
   -include("registered_names.hrl").
  --include_lib("ctool/include/test/assertions.hrl").
  --include_lib("ctool/include/test/test_node_starter.hrl").
  -
  -% TSubscribing process will wait up to this time for logs
  --define(LOGS_COUNTING_TIME, 10000).
   
   %% export for ct
   -export([all/0, init_per_testcase/2, end_per_testcase/2]).
  
positive.code: 
  count_logs(ErrorLoggerLogs, LagerLogs, Expected, StartTime) ->
      {CurrentTime, _} = statistics(wall_clock),
      case CurrentTime - StartTime < ?LOGS_COUNTING_TIME of
          false ->
              {ErrorLoggerLogs, LagerLogs};
          true ->
  
negative.code: 
      % Terminate central_logger worker
      gen_server:cast({global, ?CCM}, {stop_worker, W, central_logger}),
      nodes_manager:wait_for_cluster_cast(),
  
      % Check if traces were reset to default
      TracesAfterCleanup = rpc:call(W, ?MODULE, get_lager_traces, []),
  