pipelets refactoring, queued pipeline