comments

Author: nhsdevws

recordprocessor/src/batch_processor.py

@@ -77,9 +77,9 @@ def process_rows(file_id, vaccine, supplier, file_key, allowed_operations, creat
                 row_id = f"{file_id}^{row_count}"
                 logger.info("MESSAGE ID : %s", row_id)
                 # Log progress every 1000 rows and the first 10 rows after a restart
-                if (total_rows_processed_count % 1000 == 0):
+                if total_rows_processed_count % 1000 == 0:
                     logger.info(f"Process: {total_rows_processed_count+1}")
-                if (start_row > 0 and row_count <= start_row+10):
+                if start_row > 0 and row_count <= start_row+10:
                     logger.info(f"Restarted Process (log up to first 10): {total_rows_processed_count+1}")
 
                 # Process the row to obtain the details needed for the message_body and ack file