def batch_process()

in src/batch_processor.py [0:0]

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

def batch_process(input_products, fileName, region, dbTableName):

    try:
        for source_products in input_products:
            productIndex = source_products['productIndex']
            productId = str(source_products['productId'])
            productName = str(source_products['productName'])
            productDescription = str(source_products['productDescription'])
            
            print(str(productIndex) +" " + productId + "  " + productName + "  " + productDescription + "  " + fileName + " " + dbTableName) 
            batch_processing_job_update(productId, productName, productDescription, fileName, region, dbTableName) 
            logMessage(fileName, "Product updated for " + productId + " and " + productName + " with "+ productDescription, LOGTYPE_INFO)

    except Exception as ex:
        logMessage(fileName, "Error batch processing files " + str(ex), LOGTYPE_ERROR)