anchor.diff:      end,
       TimeFinish = os:timestamp(),
       mzb_metrics:notify({"latency", histogram}, timer:now_diff(TimeFinish, TimeStart)),
  -    {nil, State}.
  +    {nil, NewState}.
   
   run(Command, _Opts, WorkerId) ->
       {ok, Pid, _OsPid} = exec:run(Command, [monitor, stdout, stderr,
  
positive.code: 
  get_data(Port, WorkerId, _Buffer) ->
      receive
          {Stream, _Pid, Bytes} when (Stream == stdout) or (Stream == stderr) -> 
              lager:info("Worker ~p output: ~s", [WorkerId, Bytes]),
              get_data(Port, WorkerId, []);
          {'DOWN', _ , _, _, {exit_status, Code}} -> Code;
          {'DOWN', _ , _, _, normal} -> 0
      end.
  
negative.code:         ]}
      ].
  
  declare_metric(State, _Meta, Group, Title, Name, Type) ->
      mzb_metrics:declare_metric(Group, Title, Name, Type, #{}),
      {nil, State}.
  
  statsd_opts(State, _Meta, Opts) ->
      {nil, State#{statsd_opts => Opts}}.
  
  execute(State = #{statsd_spawned := StatsdSpawned}, Meta, Command) ->
      NewState =
          case StatsdSpawned of
              true -> State;
              false -> start_statsd(State)
          end,
      WorkerId = proplists:get_value(worker_id, Meta, undefined),
      lager:info("Executing ~p... on ~p~n", [Command, WorkerId]),
      TimeStart = os:timestamp(),
  