} else {
                request.addMetadata(new MetadataBridge(metadata));
            }
        }

        try {
            repoSystem.install(session, request);
        } catch (InstallationException e) {
            throw new ArtifactInstallationException(e.getMessage(), e);
        }

        /*

        runner.clean();
    }

    @Before
    public void before() throws Exception {
        try {
            runner.admin().indices().prepareDelete("_all").execute().actionGet();
        } catch (IndexNotFoundException ignore) {

        }
        runner.refresh();
        settings = Suggester.builder().build(runner.client(), id).settings();
    }

    @Test
    public void test_defaultAnalyzer() {

            throws InvocationTargetRuntimeException, IllegalAccessRuntimeException {
        assertArgumentNotNull("method", method);

        try {
            return (T) method.invoke(target, args);
        } catch (final InvocationTargetException ex) {
            final Throwable t = ex.getCause();
            if (t instanceof RuntimeException) {
                throw (RuntimeException) t;
            }

-   Continuous jobs (Run on every GitHub commit)
    -   Uses `pycpp.sh`
-   Presubmit jobs (Run on every GitHub PR)
    -   Uses `pycpp.sh`, `code_check_changed_files.sh`

These "env" files match up with an environment matrix that roughly covers:

-   Different Python versions
-   Linux, MacOS, and Windows machines (these pool definitions are internal)
-   x86 and arm64

    final int index;
    final CountDownLatch latch = new CountDownLatch(1);

    SnappyShutdownService(int index) {
      this.index = index;
    }

    @Override
    protected void run() throws Exception {
      latch.await();
    }

    @Override
    protected void triggerShutdown() {
      latch.countDown();
    }

    @Override

        return get(key) != null;
      }

      @Override
      public @Nullable V get(@Nullable Object key) {
        try {
          if (key instanceof Range) {
            @SuppressWarnings("unchecked") // we catch ClassCastExceptions
            Range<K> r = (Range<K>) key;
            if (!subRange.encloses(r) || r.isEmpty()) {
              return null;
            }
            RangeMapEntry<K, V> candidate = null;

  @Override
  public final Service startAsync() {
    if (monitor.enterIf(isStartable)) {
      try {
        snapshot = new StateSnapshot(STARTING);
        enqueueStartingEvent();
        doStart();
      } catch (Throwable startupFailure) {
        restoreInterruptIfIsInterruptedException(startupFailure);
        notifyFailed(startupFailure);
      } finally {
        monitor.leave();
        dispatchListenerEvents();

		t.Fatalf("Failed, got error: %v", err)
	}

	if result.ID != user.ID {
		t.Fatalf("result's id, %d, doesn't match user's id, %d", result.ID, user.ID)
	}
	// should find company
	if result.Company.ID != *user.CompanyID {
		t.Fatalf("result's id, %d, doesn't match user's company id, %d", result.Company.ID, *user.CompanyID)
	}
}

func TestJoinWithSoftDeleted(t *testing.T) {

        protocolHelper.init();

        try {
            protocolHelper.isValidWebProtocol(null);
            fail("Should throw exception for null URL");
        } catch (Exception e) {
            // Expected
            assertNotNull(e);
        }
    }

    public void test_isValidFileProtocol_nullUrl() {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {

            try {
                decoded.decode(buffer, 200, encoded);
                assertArrayEquals(ciphers, decoded.getCiphers());
            } catch (SMBProtocolDecodingException e) {
                fail("Should not throw exception: " + e.getMessage());
            }
        }

        @Test
        @DisplayName("Should verify cipher constants")