数据流SDK 2.7.0，同时附加安装程序2.10.0

Question

我试图运行一个数据流作业，有以下setup.py文件：

import setuptools

setuptools.setup(
              name='Some-Name',
              version='0.0.1',
              install_requires=[
                  'apache-beam==2.10.0',
                  'tensorflow-transform==0.12.0'
                  ],
              packages=setuptools.find_packages(),
              )

但是当我将作业提交给GCP时，SDK显示为2.7.0，作业将不会运行。它将在1小时后停止，并出现以下错误：

工作流失败。原因：数据流作业似乎被卡住，因为在过去1小时内未看到任何工作人员活动。

Answer 1

我通过更新本地虚拟环境中的tensorflow转换和apachebeam解决了这个问题，当时我正从中提交数据流作业。一旦我更新了本地apache beam和tensorflow变换和tensorflow变换，它似乎就可以工作了。我不知道为什么，因为设置。py说明了软件包的版本。