Skip to content

Commit f5d8c03

Browse files
committed
Remove obsolete code
1 parent bb0ef63 commit f5d8c03

File tree

2 files changed

+0
-21
lines changed

2 files changed

+0
-21
lines changed

src/processing/processor.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -155,11 +155,6 @@ def get_model(self, model_id: str) -> Model:
155155
forecast_end=model["forecastEnd"],
156156
)
157157

158-
def download_raw_data(
159-
self, upload_metadata: list[dict], directory: Path
160-
) -> tuple[list, list]:
161-
return self.storage_api.download_raw_data(upload_metadata, directory)
162-
163158
def get_model_upload(
164159
self, params: ModelParams, start_date: datetime.date, end_date: datetime.date
165160
) -> list[dict]:

src/processing/storage_api.py

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
import logging
77
import re
88
import threading
9-
import uuid
109
from os import PathLike
1110
from pathlib import Path
1211
from typing import Iterable
@@ -40,21 +39,6 @@ def upload_product(
4039
res = self._put(url, full_path, headers).json()
4140
return {"version": res.get("version", ""), "size": int(res["size"])}
4241

43-
def download_raw_data(
44-
self, metadata: list, dir_name: PathLike | str
45-
) -> tuple[list[Path], list[uuid.UUID]]:
46-
"""Download raw instrument or model files."""
47-
full_paths = self._download_parallel(
48-
metadata, checksum_algorithm="md5", output_directory=Path(dir_name)
49-
)
50-
uuids = [uuid.UUID(row["uuid"]) for row in metadata]
51-
instrument_pids = [
52-
row["instrumentPid"] for row in metadata if "instrumentPid" in row
53-
]
54-
if instrument_pids:
55-
assert len(list(set(instrument_pids))) == 1
56-
return full_paths, uuids
57-
5842
def download_product(self, metadata: dict, dir_name: PathLike | str) -> Path:
5943
"""Download a product."""
6044
filename = metadata["filename"]

0 commit comments

Comments
 (0)