We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 41194d4 commit 8d092c6Copy full SHA for 8d092c6
1 file changed
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
@@ -203,9 +203,9 @@ def __init__(
203
pool.diskSizeGb = self.worker_options.disk_size_gb
204
if self.worker_options.disk_type:
205
pool.diskType = self.worker_options.disk_type
206
- if self.worker_options.disk_provisioned_iops:
+ if self.worker_options.disk_provisioned_iops is not None:
207
pool.diskProvisionedIops = self.worker_options.disk_provisioned_iops
208
- if self.worker_options.disk_provisioned_throughput_mibps:
+ if self.worker_options.disk_provisioned_throughput_mibps is not None:
209
pool.diskProvisionedThroughputMibps = (
210
self.worker_options.disk_provisioned_throughput_mibps)
211
if self.worker_options.zone:
0 commit comments