MapReduce pipelines can fail to dispatch the shards pipeline here, which leads to "MapReduce internal error xxx...". We should clean this up to at least avoid the 'xxx'.