def getFilesPerJob()

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


def getFilesPerJob(table_name, jobid, status):
    
    table = dynamodb.Table(table_name)
    try:
        response = table.query(
            KeyConditionExpression=Key('JobId').eq(jobid),
            FilterExpression=Attr('RestoreStatus').eq(status),
            IndexName='JobIndex'
        )
    except ClientError as e:
        print(e.response['Error']['Message'])

    return response['Items']