Pipelet..add_source(): use this._fetch_source() instead of source.fetch() to filter results through this._query