gpf_check_vector.core module

Main module logic.

gpf_check_vector.core.filter_compliant_files(upload_dir: Path) → set[Path]

Filtre les fichiers vecteurs à vérifier.

La fonction prépare la liste des fichiers à vérifier

Paramètres:

upload_dir (Path) – répertoire contenant les données

Renvoie:

liste des chemins vers les données vecteurs

Type renvoyé:

set[Path]

gpf_check_vector.core.run(parameters: GpfOrchestratorParameters, upload_dir_paths: dict | None = None, number_threads: int = 5, min_files_multithread: int = 10) → tuple[Status, dict | None]

Main function to run the module logic.

Paramètres:

• parameters (GpfOrchestratorParameters) – Paramètres du traitement

• upload_dir_paths (dict) – Map des (_id, path) où path est le chemin d’accès vers les données de l’upload d’identifiant _id

• number_threads (int, optional) – nombre de threads à utiliser pour paralléliser l’exécution (nombre de fichiers vérifiés en parallèle). Si inférieur à 2, alors le traitement de chaque fichier est exécuté dans le thread principal : utile pour faciliter le debogage. Defaults to 5.

• min_files_multithread (int, optional) – nombre minimum de fichiers à vérifier pour que le multithreading soit effectivement activé

Renvoie:

statut de la vérification dict: Extent de la donnée vérifiée

Type renvoyé:

Status