@@ -105,7 +105,7 @@ def handle_exception_response(response):
105105 logger .exception ("Exception during processing" )
106106 return False , {"statusCode" : "500" , "statusDesc" : "Exception" , "diagnostics" : response }
107107
108- def handle_remove (record ):
108+ def process_remove (record ):
109109 event_id = record ["eventID" ]
110110 primary_key = record ["dynamodb" ]["Keys" ]["PK" ]["S" ]
111111 imms_id = get_imms_id (primary_key )
@@ -136,13 +136,13 @@ def handle_remove(record):
136136 operation_outcome .update (extra_log_fields )
137137 return success , operation_outcome
138138
139- def handle_skipped (record ):
139+ def process_skip (record ):
140140 primary_key = record ["dynamodb" ]["NewImage" ]["PK" ]["S" ]
141141 imms_id = get_imms_id (primary_key )
142142 logger .info ("Record from DPS skipped" )
143143 return True , {"record" : imms_id , "statusCode" : "200" , "statusDesc" : "Record from DPS skipped" }
144144
145- def handle_create_update_delete (record ):
145+ def process_create_update_delete (record ):
146146 event_id = record ["eventID" ]
147147 new_image = record ["dynamodb" ]["NewImage" ]
148148 primary_key = new_image ["PK" ]["S" ]
@@ -185,13 +185,13 @@ def handle_create_update_delete(record):
185185def process_record (record ):
186186 try :
187187 if record ["eventName" ] == EventName .DELETE_PHYSICAL :
188- return handle_remove (record )
188+ return process_remove (record )
189189
190190 supplier_system = record ["dynamodb" ]["NewImage" ]["SupplierSystem" ]["S" ]
191191 if supplier_system in ("DPSFULL" , "DPSREDUCED" ):
192- return handle_skipped (record )
192+ return process_skip (record )
193193
194- return handle_create_update_delete (record )
194+ return process_create_update_delete (record )
195195 except Exception as e :
196196 logger .exception ("Exception during processing" )
197197 return False , {"statusCode" : "500" , "statusDesc" : "Exception" , "diagnostics" : e }
0 commit comments