зеркало из https://github.com/mozilla/bugbug.git
65 строки
1.8 KiB
Python
65 строки
1.8 KiB
Python
# -*- coding: utf-8 -*-
|
|
# This Source Code Form is subject to the terms of the Mozilla Public
|
|
# License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
# You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
import logging
|
|
import lzma
|
|
import os
|
|
import shutil
|
|
from urllib.request import urlretrieve
|
|
|
|
import requests
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
LOGGER = logging.getLogger()
|
|
|
|
BASE_URL = "https://index.taskcluster.net/v1/task/project.releng.services.project.testing.bugbug_train.latest/artifacts/public"
|
|
|
|
MODELS_NAMES = ("defectenhancementtask", "component", "regression")
|
|
MODELS_DIR = os.path.join(os.path.dirname(__file__), "models")
|
|
|
|
|
|
def retrieve_model(name):
|
|
os.makedirs(MODELS_DIR, exist_ok=True)
|
|
|
|
file_name = f"{name}model"
|
|
file_path = os.path.join(MODELS_DIR, file_name)
|
|
|
|
model_url = f"{BASE_URL}/{file_name}.xz"
|
|
LOGGER.info(f"Checking ETAG of {model_url}")
|
|
r = requests.head(model_url, allow_redirects=True)
|
|
r.raise_for_status()
|
|
new_etag = r.headers["ETag"]
|
|
|
|
try:
|
|
with open(f"{file_path}.etag", "r") as f:
|
|
old_etag = f.read()
|
|
except IOError:
|
|
old_etag = None
|
|
|
|
if old_etag != new_etag:
|
|
LOGGER.info(f"Downloading the model from {model_url}")
|
|
urlretrieve(model_url, f"{file_path}.xz")
|
|
|
|
with lzma.open(f"{file_path}.xz", "rb") as input_f:
|
|
with open(file_path, "wb") as output_f:
|
|
shutil.copyfileobj(input_f, output_f)
|
|
LOGGER.info(f"Written model in {file_path}")
|
|
|
|
with open(f"{file_path}.etag", "w") as f:
|
|
f.write(new_etag)
|
|
else:
|
|
LOGGER.info(f"ETAG for {model_url} is ok")
|
|
|
|
return file_path
|
|
|
|
|
|
def preload_models():
|
|
for model_name in MODELS_NAMES:
|
|
retrieve_model(model_name)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
preload_models()
|