public void startPolling(WorkflowSystemTask systemTask, String queueName) {
        Executors.newSingleThreadScheduledExecutor()
                .scheduleWithFixedDelay(
                        () -> this.pollAndExecute(systemTask, queueName),
                        1000,
                        pollInterval,
                        TimeUnit.MILLISECONDS);
        LOGGER.info("Started listening for task: {} in queue: {}", systemTask, queueName);
    }
The worker that polls and executes an async system task.
core/src/main/java/com/netflix/conductor/core/execution/tasks/SystemTaskWorker.java