From e0bc85503b15c54c68327a0d752e8fddd0671e48 Mon Sep 17 00:00:00 2001 From: Emil Lerch Date: Wed, 25 Nov 2020 12:15:11 -0800 Subject: [PATCH] allow ability to skip event notification --- etags.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/etags.py b/etags.py index 96a3a65..b6dc7b7 100755 --- a/etags.py +++ b/etags.py @@ -81,13 +81,14 @@ def process_changes(changed): printerr('DDB did not process item with url %s' % item['PutRequest']['Item']['PK']['S']) unprocessed[item['PutRequest']['Item']['PK']['S']] = True - response = events.put_events( - Entries=[create_event(item) for item in - filter(lambda k: k['url'] not in unprocessed, changed)] - ) - if response['FailedEntryCount'] > 0: - for entry in response['Entries']: - printerr(json.dumps(entry)) + if event_bus_name != '': + response = events.put_events( + Entries=[create_event(item) for item in + filter(lambda k: k['url'] not in unprocessed, changed)] + ) + if response['FailedEntryCount'] > 0: + for entry in response['Entries']: + printerr(json.dumps(entry)) def make_requests(urls, existing_etags):