assertNotNull(capturedBody.get());
        assertTrue(capturedBody.get().contains("\"heartbeat\""));
        assertTrue(capturedBody.get().contains("\"expiredTime\""));
        assertTrue(capturedBody.get().contains("\"gte\""));
        assertTrue(capturedBody.get().contains("\"size\":100"));
        assertTrue(capturedPath.get().contains("/_search"));
    }

    @Test
    public void test_fetchNewEvents_queryStructure() {

    defaults:
      run:
        shell: bash
    container: ${{ (contains(inputs.runner, 'linux-x86') && 'us-docker.pkg.dev/ml-oss-artifacts-published/ml-public-container/ml-build:latest') ||
                   (contains(inputs.runner, 'linux-arm64') && 'us-docker.pkg.dev/ml-oss-artifacts-published/ml-public-container/ml-build-arm64:latest') ||
                   (contains(inputs.runner, 'windows-x86') && null) }}
    timeout-minutes: 300
    steps:

  }

  @Override
  public int size() {
    return contents.length;
  }

  @Override
  public boolean contains(@Nullable Object object) {
    if (!allowNulls) {
      // behave badly
      checkNotNull(object);
    }
    Platform.checkCast(type, object); // behave badly
    return asList(contents).contains(object);
  }

  @Override
  public boolean containsAll(Collection<?> collection) {
    if (!allowNulls) {

    }
  }

  /**
   * Returns {@code true} if this queue contains the specified element. More formally, returns
   * {@code true} if and only if this queue contains at least one element {@code e} such that {@code
   * o.equals(e)}.
   *
   * @param o object to be checked for containment in this queue
   * @return {@code true} if this queue contains the specified element
   */

  }

  @Override
  public int size() {
    return contents.length;
  }

  @Override
  public boolean contains(@Nullable Object object) {
    if (!allowNulls) {
      // behave badly
      checkNotNull(object);
    }
    Platform.checkCast(type, object); // behave badly
    return asList(contents).contains(object);
  }

  @Override
  public boolean containsAll(Collection<?> collection) {
    if (!allowNulls) {

        assertTrue(localLogMsg.get().contains("\"ecs.version\":\"2.0.0\""));
    }

    @Test
    public void test_setEcsServiceName() {
        activityHelper.setEcsServiceName("test-service");
        activityHelper.useEcsFormat = true;
        activityHelper.login(OptionalThing.empty());
        assertTrue(localLogMsg.get().contains("\"service.name\":\"test-service\""));
    }

    @Test

  }

  /**
   * Returns {@code true} if this fluent iterable contains any object for which {@code
   * equals(target)} is true.
   *
   * <p><b>{@code Stream} equivalent:</b> {@code stream.anyMatch(Predicate.isEqual(target))}.
   */
  public final boolean contains(@Nullable Object target) {
    return Iterables.contains(getDelegate(), target);
  }

  /**

  }

  /**
   * Returns {@code true} if this fluent iterable contains any object for which {@code
   * equals(target)} is true.
   *
   * <p><b>{@code Stream} equivalent:</b> {@code stream.anyMatch(Predicate.isEqual(target))}.
   */
  public final boolean contains(@Nullable Object target) {
    return Iterables.contains(getDelegate(), target);
  }

  /**

        final String p = path.trim();
        if (p.startsWith("#")) {
            return StringUtils.EMPTY;
        }

        if (p.startsWith(GsaConfigParser.CONTAINS)) {
            return ".*" + Pattern.quote(p.substring(GsaConfigParser.CONTAINS.length())) + ".*";
        }

        if (p.startsWith(GsaConfigParser.REGEXP)) {
            return p.substring(GsaConfigParser.REGEXP.length());
        }

        assertEquals(1, events.size());
        assertNotNull(events.get(0).getThrowable());
        assertTrue(events.get(0).getThrowable().contains("RuntimeException"));
        assertTrue(events.get(0).getThrowable().contains("test exception"));
        assertTrue(events.get(0).getThrowable().length() <= 500);
    }

    @Test
    public void test_append_nullLoggerName() {