void transitionToRunning() {
            state = State.RUNNING;
            timeoutFuture = scheduler.schedule(stateChangeExecutor,
                new StopWorker(workerId, false),
                Math.max(0, spec.endMs() - time.milliseconds()));
        }
Whether we should destroy the records of this worker once it stops.
trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java