presto-main/src/main/java/io/prestosql/execution/QueryStateMachine.java/QueryOutputManager/fireStateChanged
class QueryOutputManager:        private void fireStateChanged(QueryOutputInfo queryOutputInfo, List<Consumer<QueryOutputInfo>> outputInfoListeners)
        {
            for (Consumer<QueryOutputInfo> outputInfoListener : outputInfoListeners) {
                executor.execute(() -> outputInfoListener.accept(queryOutputInfo));
            }
        }