added object input support to forEachPipeline