Skip to content

Commit e23c44c

Browse files
authored
Merge pull request #654 from lsieradzki/bugfix/issue-653
#653
2 parents 56199b7 + 6794d18 commit e23c44c

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
bugfixes:
2+
- gcp_pubsub_subscription - improper subscription uprade PATCH request

plugins/modules/gcp_pubsub_subscription.py

+7-4
Original file line numberDiff line numberDiff line change
@@ -634,8 +634,9 @@ def create(module, link):
634634
def update(module, link, fetch):
635635
auth = GcpSession(module, 'pubsub')
636636
params = {'updateMask': updateMask(resource_to_request(module), response_to_hash(module, fetch))}
637-
request = resource_to_request(module)
638-
del request['name']
637+
subscription = resource_to_request(module)
638+
del subscription['name']
639+
request = {'subscription': subscription}
639640
return return_if_object(module, auth.patch(link, request, params=params))
640641

641642

@@ -651,7 +652,7 @@ def updateMask(request, response):
651652
update_mask.append('messageRetentionDuration')
652653
if request.get('retainAckedMessages') != response.get('retainAckedMessages'):
653654
update_mask.append('retainAckedMessages')
654-
if request.get('expirationPolicy') != response.get('expirationPolicy'):
655+
if request.get('expirationPolicy') and request.get('expirationPolicy') != response.get('expirationPolicy'):
655656
update_mask.append('expirationPolicy')
656657
if request.get('deadLetterPolicy') != response.get('deadLetterPolicy'):
657658
update_mask.append('deadLetterPolicy')
@@ -838,7 +839,9 @@ def __init__(self, request, module):
838839
self.request = {}
839840

840841
def to_request(self):
841-
return remove_nones_from_dict({u'ttl': self.request.get('ttl')})
842+
ttl = self.request.get('ttl')
843+
ttl = None if ttl == "" else ttl
844+
return remove_nones_from_dict({u'ttl': ttl})
842845

843846
def from_response(self):
844847
return remove_nones_from_dict({u'ttl': self.request.get(u'ttl')})

0 commit comments

Comments
 (0)