lobo/etags
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

allow ability to skip event notification

Browse source
This commit is contained in:
Emil Lerch 2020-11-25 12:15:11 -08:00
parent bbc4920c4c
commit e0bc85503b
Signed by: lobo
GPG key ID: A7B62D657EF764F8
1 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
etags.py
View file

@ -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):