def dynamodb_insert()

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

• 16 lines of code
• 2 McCabe index (conditional complexity)

def dynamodb_insert(job_id, data, batch_job):
    num_files = len(data)

    files_table = dynamodb.Table(FILES_TABLE)
    jobs_table = dynamodb.Table(JOBS_TABLE)
    items = map(get_item_mapper(job_id), data)

    with files_table.batch_writer() as batch:
        for item in items:
            batch.put_item(Item=item)

    jobs_table.put_item(
        Item={
            "JobId": job_id,
            "TotalFiles": num_files,
            "BatchJobId": batch_job["JobId"],
            "Timestamp": datetime.datetime.utcnow().isoformat()
        })

    return num_files