Update gcp_pubsub_subscription.py

Fix lint errors
This commit is contained in:
Chris Hawk 2024-11-11 16:40:47 -08:00 committed by GitHub
parent 198adf8cfd
commit 68c9af276c
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -89,7 +89,7 @@ options:
description: description:
- File object datetime format stored in a Bucket. - File object datetime format stored in a Bucket.
required: false required: false
type: str type: str
max_duration: max_duration:
description: description:
- Subscription writes a new output file if the specified value of max duration is exceeded. Min: 60s, max: 600s. - Subscription writes a new output file if the specified value of max duration is exceeded. Min: 60s, max: 600s.
@ -104,7 +104,7 @@ options:
description: description:
- Cloud Storage Subscription writes a new output file if the specified number of messages is exceeded. Min: 1000. - Cloud Storage Subscription writes a new output file if the specified number of messages is exceeded. Min: 1000.
required: false required: false
type: int type: int
output_format: output_format:
description: description:
- Specify the format of the output files that are to be stored in a Cloud Storage bucket as text or avro. - Specify the format of the output files that are to be stored in a Cloud Storage bucket as text or avro.
@ -958,6 +958,7 @@ class SubscriptionRetrypolicy(object):
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'minimumBackoff': self.request.get(u'minimumBackoff'), u'maximumBackoff': self.request.get(u'maximumBackoff')}) return remove_nones_from_dict({u'minimumBackoff': self.request.get(u'minimumBackoff'), u'maximumBackoff': self.request.get(u'maximumBackoff')})
class SubscriptionCloudStorageConfig(object): class SubscriptionCloudStorageConfig(object):
def __init__(self, request, module): def __init__(self, request, module):
self.module = module self.module = module