in src/dynamo_db/index.py [0:0]
def handler(event, _):
"""
Lambda handler
"""
event_input = event["input"]
job_details = event["job_details"]
try:
job_output = str(event["jobstatus"][1]["StandardOutputContent"])
except (IndexError, KeyError):
job_output = "null"
return DDB.put_item(
TableName=event_input["table"],
Item={
"job_id": {
"S": job_details["job_id"],
},
"Status": {
"S": event["status"],
},
"Retries": {
"S": "{} of {}".format(job_details["re_run"], job_details["retry"]),
},
"SSM_Document": {
"S": job_details["ssm_document"],
},
"Commands": {
"S": str(job_details["commands"]),
},
"Output_Logs": {
"S": job_output,
},
"instance_id": {
"S": event_input["instance_id"],
}
}
)