def getJobStatusAndUpdateTable()

in src/timetriggerSNS/app.py [0:0]

• 22 lines of code
• 7 McCabe index (conditional complexity)

def getJobStatusAndUpdateTable(table_name, batchJobid, jobid):

    failedFiles=0
    table = dynamodb.Table(table_name)
    
    try:
        response = s3_control_client.describe_job(
            AccountId=account_id ,
            JobId=batchJobid
        )
        if response:
            if 'Job' in response:
                batchStatus = response['Job']['Status']

                if batchStatus == 'Complete':
                    status = 'Restoring'
                else:
                    status = batchStatus
                
                if 'ProgressSummary' in response['Job']:
                    failedFiles = response['Job']['ProgressSummary']['NumberOfTasksFailed']


                if batchStatus in finished_BatchOps_states:
                    
                    #update
                    UpdateJobItemBatchStatus(table_name, jobid, status, batchStatus , failedFiles)
                
    except ClientError as e:
        print(e.response['Error']['Message'])
    
    return status, failedFiles