fixup! added InsertFromSubQueryConsumer