From 2deffbb69a1ad2bac02ef2eda2bb347ed3df2905 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arturo=20Filast=C3=B2?= Date: Fri, 20 Dec 2024 15:53:50 +0100 Subject: [PATCH] Use absolute path for oonipipeline import --- dags/{dags.py => pipeline.py} | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) rename dags/{dags.py => pipeline.py} (95%) diff --git a/dags/dags.py b/dags/pipeline.py similarity index 95% rename from dags/dags.py rename to dags/pipeline.py index 51f1b285..73e686ce 100644 --- a/dags/dags.py +++ b/dags/pipeline.py @@ -1,3 +1,4 @@ +import pathlib import datetime from typing import List @@ -43,7 +44,7 @@ def run_make_analysis( make_analysis_in_a_day(params) -REQUIREMENTS = ["./oonipipeline"] +REQUIREMENTS = [str((pathlib.Path(__file__).parent.parent / "oonipipeline").absolute())] with DAG( dag_id="batch_measurement_processing",