我有一个从网站抓取数据并将数据加载到Bigquery的批处理作业 import apache_beam as beam # scrape但我的问题是,我想在"load to bq“之后添加另一个进程(作为一个普通的python函数),而不需要任何"load to bq”的输出结果。中的函数。该函数未在数据流控制台中显示,并且也未运行。()得到了0个参数 那么,如何将此函数包含到beam</em
File "apache_beam/runners/common.py", line 1401, in apache_beam.runners.common."apache_beam/runners/common.py", line 1401, in apache_beam.runners.common.common.v1.common_pb2' failed [