in lib/integration-test/lambda/delete_s3_objects.py [0:0]
def clean_s3(event, context):
LOGGER.info("Received event: %s", event)
try:
d = event
delete_s3_objects(d['FirehoseOutputBucket'])
return event
except Exception as e:
# Trace error
LOGGER.exception("Error while deleting data from S3.")
return {"status": "FAILED", "error_message": str(e), "guid": event}