Skip to content

Commit a25a2b2

Browse files
committed
Add data coverage
1 parent 36e5001 commit a25a2b2

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

src/processing/processor.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -542,6 +542,9 @@ def upload_quality_report(
542542
result = error_level.value
543543
break
544544
self.md_api.put("quality", str(uuid), quality_dict)
545+
if quality_report.data_coverage is not None:
546+
payload = {"uuid": str(uuid), "coverage": quality_report.data_coverage}
547+
self.md_api.post("files", payload)
545548
return result
546549

547550

src/processing/utils.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import netCDF4
1212
import numpy as np
1313
import requests
14+
from cloudnetpy_qc.coverage import data_coverage
1415
from numpy import ma
1516
from requests.adapters import HTTPAdapter
1617
from urllib3.util.retry import Retry
@@ -120,6 +121,7 @@ def create_product_put_payload(
120121
"software": {"cloudnet-processing": get_data_processing_version()},
121122
"startTime": start_time,
122123
"stopTime": stop_time,
124+
"coverage": data_coverage(nc)[0],
123125
**storage_service_response,
124126
}
125127
if instrument_pid := getattr(nc, "instrument_pid", None):

0 commit comments

Comments
 (0)