anchor.diff:  
       % Terminate central_logger worker
       gen_server:cast({global, ?CCM}, {stop_worker, W, central_logger}),
  -    test_utils:wait_for_cluster_cast(),
  +    nodes_manager:wait_for_cluster_cast(),
   
       % Check if traces were reset to default
       TracesAfterCleanup = rpc:call(W, ?MODULE, get_lager_traces, []),
  
positive.code: %% central_logger subscribing and log stream
  
  logging_test(Config) ->
      NodesUp = ?config(nodes, Config),
      [CCM, W1, W2, W3, W4] = NodesUp,
  
      % Init cluster
      gen_server:cast({?Node_Manager_Name, CCM}, do_heart_beat),
      gen_server:cast({global, ?CCM}, {set_monitoring, on}),
      test_utils:wait_for_cluster_cast(),
      test_utils:wait_for_nodes_registration(length(NodesUp) - 1),
      gen_server:cast({global, ?CCM}, init_cluster),
      test_utils:wait_for_cluster_init(),
  
      % Subscribe for log stream
      Pid = self(),
  
negative.code:     % Init cluster
      gen_server:cast({?Node_Manager_Name, CCM}, do_heart_beat),
      gen_server:cast({global, ?CCM}, {set_monitoring, on}),
      nodes_manager:wait_for_cluster_cast(),
      gen_server:cast({global, ?CCM}, init_cluster),
      nodes_manager:wait_for_cluster_init(),
  
      % Test logger's console loglevel switching functionalities
      ?assertEqual(ok, rpc:call(W, ?MODULE, check_console_loglevel_functionalities, [])),
  