debug

Author: nhsdevws

e2e_batch/Makefile

@@ -12,7 +12,10 @@ run-immunization-batch:
 	ENVIRONMENT=$(environment) poetry run python -m unittest -v -c
 
 test:
+	ENVIRONMENT=$(environment) poetry run python -m unittest -v -c
+
+testp1:
 	ENVIRONMENT=$(ENVIRONMENT) time poetry run unittest-parallel -v -j $(PARALLEL_WORKERS)
 
-test2:
+testp2:
 	ENVIRONMENT=$(ENVIRONMENT) poetry run pytest -n $(PARALLEL_WORKERS) -v

e2e_batch/utils.py

@@ -86,10 +86,11 @@ def generate_csv(fore_name, dose_amount, action_flag, headers="NHS_NUMBER", same
 
     df = pd.DataFrame(data)
     timestamp = datetime.now(timezone.utc).strftime("%Y%m%dT%H%M%S%f")[:-3]
+    # "RSV", "YGM41"
     file_name = (
-        f"COVID19_Vaccinations_v4_YGM41_{timestamp}.csv"
+        f"RSV_Vaccinations_v4_YGM41_{timestamp}.csv"
         if file_key
-        else f"COVID19_Vaccinations_v5_YGM41_{timestamp}.csv"
+        else f"RSV_Vaccinations_v5_YGM41_{timestamp}.csv"
     )
     # file_name = get_file_name(vax_type, ods, "4" if file_key else "5")
     df.to_csv(file_name, index=False, sep="|", quoting=csv.QUOTE_MINIMAL)

recordprocessor/src/utils_for_recordprocessor.py

@@ -16,6 +16,8 @@ def get_environment() -> str:
 def get_csv_content_dict_reader(file_key: str) -> DictReader:
     """Returns the requested file contents from the source bucket in the form of a DictReader"""
     logger.info("SAW> get_csv_content_dict_reader..1")
+    logger.info("SAW> Fetch file: %s", file_key)
+    logger.info("SAW> SOURCE_BUCKET_NAME: %s", os.getenv("SOURCE_BUCKET_NAME"))
     response = s3_client.get_object(Bucket=os.getenv("SOURCE_BUCKET_NAME"), Key=file_key)
     logger.info("SAW> get_csv_content_dict_reader..2")
     binary_io = response["Body"]