anchor.diff:              ]),
               failure
           end,
  -        gen_server2:cast(?NODE_MANAGER_NAME, {async_cluster_init_step_result, db_and_workers_ready, Result})
  +        report_step_result(db_and_workers_ready, Result)
       end),
       async;
   cluster_init_step(start_listeners) ->
  
positive.code:                 [Step, Error, Reason]),
              report_step_result(Step, failure)
      end,
      {noreply, State};
  
  handle_cast({async_cluster_init_step_result, Step, Result}, State) ->
      report_step_result(Step, Result),
      {noreply, State};
  
  handle_cast(node_initialized, State) ->
  
negative.code:             {cluster_ready, ok} -> ok;
              % report the result to cluster manager
              {_, ok} -> report_step_result(Step, success);
              % result will be reported by the async process that is handling the step
              {_, async} -> ok
          end
      catch
  