Pipelet._add_source(): provide query to _add_destination() when inserting a Union