DAG: Collahuasi_Metrics Functions that calculated metrics related to models in Sierra Gorda

schedule: 30 12 * * 1

Collahuasi_Metrics

Toggle wrap 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
# Airflow dependencies
from asyncio import Task
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.utils.dates import days_ago
from airflow.models import Variable
from airflow.operators.dagrun_operator import TriggerDagRunOperator

# Python dependencies
import sys
import os

from datetime import timedelta
from datetime import datetime 
from datetime import timedelta

# Dependencias propias

from utils.settings import RAW_CONTAINER, METRICS_CONTAINER, YEAR, MONTH, DAY
from utils.metrics import calculate_estimated_bench_metric

# Default arguments
default_args = {
    'owner': 'Pedro',
    'start_date': datetime(2024, 4, 26, 0, 0, 0)
}

# Instanciate the DAG object
collahuasi_metric_dag = DAG( ## Cambiar esto a cammel case.
    'Collahuasi_Metrics',
    default_args=default_args,
    description='Functions that calculated metrics related to models in Sierra Gorda',
    schedule_interval= '30 12 * * 1', # Viernes a las 12:30 todas las semanas
    catchup=False,
    is_paused_upon_creation=True
)

"""
    Tareas de cruce entre Perforaciones y Opit
"""
metrics_collahuasi_task1 = PythonOperator(
    task_id = 'Metrics_GenerateScore_BenchEstimation',
    python_callable = calculate_estimated_bench_metric,
    op_kwargs = {"app_points_container": RAW_CONTAINER, 
                 "app_points_blob": f"Collahuasi/dxf/puntos_05_03.json",
                 "mine_opit": "'COLLAHUASI'",
                 "mine_dxf_polygon": "Collahuasi",
                 "classifier_model_path": "utils/models/Collahuasi/clasificador.pkl",
                 "final_container": METRICS_CONTAINER,
                 "final_blob": f"Collahuasi/Estimate bench/{YEAR}/{MONTH}/{DAY}/BenchEstimation_v1.json"},
    dag = collahuasi_metric_dag,
)

# Define task secuence 
metrics_collahuasi_task1