presto-main/src/main/java/io/prestosql/operator/WorkProcessorPipelineSourceOperator.java/WorkProcessorPipelineSourceOperatorFactory/noMoreOperators
class WorkProcessorPipelineSourceOperatorFactory:        @Override
        public void noMoreOperators(Lifespan lifespan)
        {
            this.operatorFactories.forEach(operatorFactory -> operatorFactory.lifespanFinished(lifespan));
        }