break;
                case TEARDOWN:
                    attachToThread(step);

                    // Check if there are any stored exceptions for this project
                    List<Throwable> failures = null;
                    boolean allStepsExecuted = true;
                    for (BuildStep projectStep : plan.steps(step.project).toList()) {
                        Exception exception = projectStep.exception;

```

**Async Operations:**
```java
suggester.suggest()
    .setQuery("search")
    .execute()
    .done(response -> { /* handle success */ })
    .error(throwable -> { /* handle error */ });
```

---

## Important Notes

### Thread Safety
- **Suggester**: Thread-safe for queries
- **SuggestIndexer**: Thread-safe for indexing

            } else if (logger.isInfoEnabled()) {
                logger.info("Crawler is stopped.");
            }
            exitCode = Constants.EXIT_FAIL;
        } catch (final Throwable t) {
            logger.error("Crawler terminated unexpectedly.", t);
            exitCode = Constants.EXIT_FAIL;
        } finally {
            if (commandThread != null && commandThread.isAlive()) {

    private
    inline fun tryResolve(resolver: () -> String, or: () -> String) = try {
        resolver()
    } catch (_: Throwable) {
        or()
    }
}


private
val NEWLINE_REGEX = "\\n\\s*".toRegex()


private
class KotlinVersionsToIncubatingCollector(val repositoryRoot: Path) : VersionsToIncubatingCollector {

        when(handle.getFileId()).thenReturn(new byte[16]);
        when(tree.send(any(CommonServerMessageBlockRequest.class), any(), any(), any()))
                .thenThrow(new SmbException(0xC0000120, (Throwable) null));
        SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0, false);

        List<FileNotifyInformation> result = sut.watch();

        assertNull(result, "Cancelled watch should return null");

            task = withLock {
              afterRun(task, delayNanos, true)
              awaitTaskToRun()
            } ?: return
          }
        } catch (thrown: Throwable) {
          // A task failed. Update execution state and re-throw the exception.
          withLock {
            afterRun(task, -1L, false)
          }
          if (thrown is InterruptedException) {

        public void stop() {
            /* No-op */ }
    }

    private static class FastMockFailureUrlService extends FailureUrlService {
        public void store(DataConfig dataConfig, String errorName, String url, Throwable e) {
            /* No-op */ }
    }

    private static class FastMockSearchEngineClient extends SearchEngineClient {
        @Override
        public long deleteByQuery(String index, QueryBuilder queryBuilder) {

  }

  private static final class TimeoutFutureException extends TimeoutException {
    private TimeoutFutureException(String message) {
      super(message);
    }

    @Override
    public synchronized Throwable fillInStackTrace() {
      setStackTrace(new StackTraceElement[0]);
      return this; // no stack trace, wouldn't be useful anyway
    }
  }

  @Override
  protected @Nullable String pendingToString() {

        }
    }

    /**
     * {@inheritDoc}
     *
     * @see java.lang.Object#finalize()
     */
    @Override
    protected void finalize() throws Throwable {
        try {
            if (this.usageCount != null && this.usageCount.get() != 0 && this.open) {
                log.warn("File handle was not properly closed, performing emergency cleanup: " + this);

            } else if (logger.isInfoEnabled()) {
                logger.info("SuggestCreator is stopped.");
            }
            exitCode = Constants.EXIT_FAIL;
        } catch (final Throwable t) {
            logger.error("SuggestCreator terminated unexpectedly.", t);
            exitCode = Constants.EXIT_FAIL;
        } finally {
            if (systemMonitorTask != null) {