lint

Author: JamesW1-NHS

recordprocessor/src/batch_processor.py

@@ -16,6 +16,7 @@
 def ingestion_progress(finished: bool, message_body: dict, row_count: int = 0, start_time: float = 0.0) -> str:
     return("Ingestion finished" if finished else "Ingestion started")
 
+
 def process_csv_to_fhir(incoming_message_body: dict) -> None:
     """
     For each row of the csv, attempts to transform into FHIR format, sends a message to kinesis,

recordprocessor/src/logging_decorator.py

@@ -70,6 +70,7 @@ def wrapper(*args, **kwargs):
 
     return wrapper
 
+
 def ingestion_logging_decorator(func):
     """
     Sends the appropriate logs to Cloudwatch and Firehose based on ingestion started/finished.

recordprocessor/tests/test_logging_decorator.py

@@ -254,4 +254,4 @@ def test_splunk_logger_unhandled_failure(self):
             DeliveryStreamName=Firehose.STREAM_NAME, Record=expected_firehose_record
         )
 
-# TODO: unit tests for ingestion decorator
+# TODO: unit tests for ingestion decorator