DAG: report_drilling_status_SierraGorda Functions that generated reports related to Sierra Gorda

schedule: 30,30 17,1 * * *

report_drilling_status_SierraGorda

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
# 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 jinja2 import Template
from functools import reduce
from datetime import datetime, timedelta
from standardized_process.dags.functions.reporte_perforacion_sg import carga_datos, generar_tablas_reportes, generate_report

import json 
import os 

task_loaded = False

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

sg_report_dag = DAG(
    'report_drilling_status_SierraGorda',
    default_args=default_args,
    description='Functions that generated reports related to Sierra Gorda',
    schedule_interval= '30,30 17,1 * * *',# Hora local 13:30 y 21:30
    catchup=False,
    is_paused_upon_creation=True
)


task1 = PythonOperator(
    task_id = 'carga_datos',
    python_callable = carga_datos,
    dag = sg_report_dag,
)

task2 = PythonOperator(
    task_id = 'generar_tablas',
    python_callable = generar_tablas_reportes,
    dag = sg_report_dag,
)

task3 = PythonOperator(
    task_id = 'generar_reporte',
    python_callable = generate_report,
    dag = sg_report_dag,
)

task1 >> task2 >> task3