You can accomplish this in multiple ways. There is already an example how to query BigQuery in the article, you can reuse that and adapt to your need. It's up to you if you want to be a GCF API result or GCW step. It really depends on the manipulation of data. GCF is favored for data manipulation. GCW is favored for quick conditional check and continuing the pipeline.