Pass site coordinates to QC

Author: siiptuo

src/processing/instrument.py

@@ -71,7 +71,7 @@ def process_instrument(processor: Processor, params: InstrumentParams, directory
         new_file, params.product.id, std_uuid.UUID(uuid.product), filename, directory
     )
     qc_result = processor.upload_quality_report(
-        new_file, std_uuid.UUID(uuid.product), params.product.id
+        new_file, std_uuid.UUID(uuid.product), params.site, params.product.id
     )
     processor.update_statuses(uuid.raw, "processed")
     utils.print_info(uuid, volatile, patch, upload, qc_result)

src/processing/jobs.py

@@ -37,7 +37,9 @@ def update_plots(processor: Processor, params: ProcessParams, directory: Path) -
 def update_qc(processor: Processor, params: ProcessParams, directory: Path) -> None:
     metadata, full_path = _fetch_data(processor, params, directory)
     file_uuid = uuid.UUID(metadata["uuid"])
-    result = processor.upload_quality_report(full_path, file_uuid, params.product.id)
+    result = processor.upload_quality_report(
+        full_path, file_uuid, params.site, params.product.id
+    )
     url = f"{utils.build_file_landing_page_url(str(file_uuid))}/quality"
     logging.info(f"Created quality report: {url} {result.upper()}")
 

src/processing/model.py

@@ -93,7 +93,7 @@ def process_model(processor: Processor, params: ModelParams, directory: Path):
             processor.create_and_upload_images(
                 new_file, "model", product_uuid, filename, directory
             )
-        qc_result = processor.upload_quality_report(new_file, product_uuid)
+        qc_result = processor.upload_quality_report(new_file, product_uuid, params.site)
         _print_info(product_uuid, qc_result)
         processor.update_statuses(raw_uuids, "processed")
     except MiscError as err:

src/processing/processor.py

@@ -486,13 +486,19 @@ def _upload_img(
         }
 
     def upload_quality_report(
-        self, full_path: Path, uuid: uuid.UUID, product: str | None = None
+        self, full_path: Path, uuid: uuid.UUID, site: Site, product: str | None = None
     ) -> str:
         try:
             # is_dev = self.config.get("PID_SERVICE_TEST_ENV", "").lower() == "true"
             # ignore_tests = ["TestInstrumentPid"] if is_dev else None
+            site_meta: quality.SiteMeta = {
+                "latitude": site.latitude,
+                "longitude": site.longitude,
+                "altitude": site.altitude,
+            }
             quality_report = quality.run_tests(
                 full_path,
+                site_meta,
                 product=product,  # ignore_tests=ignore_tests
             )
         except ValueError:

src/processing/product.py

@@ -77,7 +77,7 @@ def process_me(processor: Processor, params: ModelParams, directory: Path):
         directory,
     )
     qc_result = processor.upload_quality_report(
-        new_file, std_uuid.UUID(uuid.product), params.product.id
+        new_file, std_uuid.UUID(uuid.product), params.site, params.product.id
     )
     utils.print_info(uuid, volatile, patch, upload, qc_result)
 
@@ -148,7 +148,7 @@ def process_product(processor: Processor, params: ProductParams, directory: Path
         directory,
     )
     qc_result = processor.upload_quality_report(
-        new_file, std_uuid.UUID(uuid.product), params.product.id
+        new_file, std_uuid.UUID(uuid.product), params.site, params.product.id
     )
     utils.print_info(uuid, volatile, patch, upload, qc_result)
     if processor.md_api.config.is_production: