update_processor.py

from dynamo_operations import update_item_finished

...
SG_PROCESSES_TABLE_NAME = os.getenv('SG_PROCESSES_TABLE_NAME')
...


@logger.inject_lambda_context
def lambda_handler(event, context):
    ...

		# Update the status item in Dynamo
    item_state = json_body.get("item_state")
    update_item_finished(SG_PROCESSES_TABLE_NAME, item_state)
    logger.info({"action":"update_item", "payload":{"item_state":item_state}})