From b93b290f97481fa0c3696c6198a418f78be26128 Mon Sep 17 00:00:00 2001 From: Colin Maudry Date: Fri, 19 Sep 2025 08:26:03 +0200 Subject: [PATCH] =?UTF-8?q?Lazyframe=20d=C3=A8s=20le=20d=C3=A9part?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/utils.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/utils.py b/src/utils.py index 5efe954..3c6856e 100644 --- a/src/utils.py +++ b/src/utils.py @@ -110,14 +110,12 @@ def get_decp_data() -> pl.LazyFrame: logger.info( f"Lecture du fichier parquet ({os.getenv('DATA_FILE_PARQUET_PATH')})..." ) - df: pl.DataFrame = pl.read_parquet(os.getenv("DATA_FILE_PARQUET_PATH")) + lff: pl.LazyFrame = pl.scan_parquet(os.getenv("DATA_FILE_PARQUET_PATH")) except ComputeError: # Le fichier est probablement en cours de mise à jour logger.info("Échec, nouvelle tentative dans 10s...") sleep(10) - df: pl.DataFrame = pl.read_parquet(os.getenv("DATA_FILE_PARQUET_PATH")) - - lff: pl.LazyFrame = df.lazy() + lff: pl.LazyFrame = pl.scan_parquet(os.getenv("DATA_FILE_PARQUET_PATH")) # Remplacement des valeurs numériques par des chaînes de caractères # lff = numbers_to_strings(lff)