anchor.diff:    ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code2, [])),
     test_utils:wait_for_cluster_init(DuplicatedPermanentNodes),
     {Workers, _} = gen_server:call({global, ?CCM}, get_workers),
  -
  -  {ok, MonitoringInitialization} = rpc:call(CCM, application, get_env, [?APP_Name, cluster_monitoring_initialization]),
  -  timer:sleep(2 * 1000 * MonitoringInitialization),
  +  ct:print("workers ~p",[Workers]),
  +
   
     % Init cluster
   
  
positive.code: 
    receive
      ok -> ok
    after 2000 ->
      ?assert(false)
    end,
  
  
negative.code: 
    lists:foreach(fun(Node) -> StartAdditionalWorker(Node, cluster_rengine) end, NodesUp),
    test_utils:wait_for_cluster_init(DuplicatedPermanentNodes + length(NodesUp) - 1),
    timer:sleep(30000),
    {Workers2, _} = gen_server:call({global, ?CCM}, get_workers),
    ct:print("workers ~p",[Workers2]),
    lists:append([{nodes, NodesUp}], Config).
  
  end_per_testcase(distributed_test, Config) ->
  