Pipelet: ..emit() comment-out try block; ..add_source() add current query as a parameter to fetch