anchor.diff:                  meck:passthrough(PassthroughArgs);
               delay_and_fail_call ->
                   DelayFun(),
  +                OnFailFun(),
                   error;
               throw_error ->
                   meck:passthrough(PassthroughArgs),
  
positive.code: mock_handlers(Workers, Manager) ->
      test_utils:mock_new(Workers, [workflow_test_handler, workflow_engine_callback_handler]),
  
      MockTemplateWithDelay = fun(HandlerCallReport, PassthroughArgs, DelayFun) ->
          Manager ! {handler_call, self(), HandlerCallReport},
          receive
              history_saved ->
                  meck:passthrough(PassthroughArgs);
              fail_call ->
                  error;
              delay_call ->
                  DelayFun(),
  
negative.code:                         _ ->
                              wait_for_lane_finish(ExecutionId, integer_to_binary(binary_to_integer(LaneId) - 1))
                      end
                  end,
                  fun() ->
                      op_worker:set_env({lane_finished, ExecutionId, LaneId}, true)
                  end
              )
      end),
  