public synchronized void init() {
        this.taskPollExecutor =
                new TaskPollExecutor(
                        eurekaClient,
                        taskClient,
                        updateRetryCount,
                        taskToDomain,
                        workerNamePrefix,
                        taskThreadCount);

        this.scheduledExecutorService = Executors.newScheduledThreadPool(workers.size());
        workers.forEach(
                worker ->
                        scheduledExecutorService.scheduleWithFixedDelay(
                                () -> taskPollExecutor.pollAndExecute(worker),
                                worker.getPollingInterval(),
                                worker.getPollingInterval(),
                                TimeUnit.MILLISECONDS));
    }
Starts the polling. Must be called after {@link TaskRunnerConfigurer.Builder#build()} method.
client/src/main/java/com/netflix/conductor/client/automator/TaskRunnerConfigurer.java