def updateDocumentStatus()

in code/metadata/pipeline.py [0:0]

• 25 lines of code
• 3 McCabe index (conditional complexity)

def updateDocumentStatus(documentPayload, receipt, messageNote=None):
    print("Putting pipeline document status update")
    client = PipelineOpsStore(PIPELINE_OPS_TABLE)
    if messageNote:
        statusPayload = {
            "documentId": documentPayload['documentId'],
            "status":     documentPayload['status'],
            "stage":      documentPayload['stage'],
            "timestamp":  documentPayload['timestamp'],
            "message":    messageNote
        }
    else:
        statusPayload = {
            "documentId": documentPayload['documentId'],
            "status":     documentPayload['status'],
            "stage":      documentPayload['stage'],
            "timestamp":  documentPayload['timestamp']
        }
    res = client.updateDocumentStatus(**statusPayload)
    print(res)
    if res['Status'] == 200:
        SQSHelper().deleteMessage(SQS_QUEUE_ARN, receipt)
    else:
        raise Exception("Unable to update status of document {}: {}".format(statusPayload['documentId'], res['Error']))
    return res