No tienes acceso a esta clase

隆Contin煤a aprendiendo! 脷nete y comienza a potenciar tu carrera

Custom Operator

15/29
Recursos

Aportes 4

Preguntas 3

Ordenar por:

驴Quieres ver m谩s aportes, preguntas y respuestas de la comunidad?

鉁 Un buen truco para evitar que el dag no se ejecute desde la fecha de inicio hasta ahora es usar el parametro catchup=False

LLegue a salvarles la vida perros

CLASE 鈥渃ustomoperator鈥

from airflow import DAG
from datetime import datetime
from hellooperator import HelloOperator

with DAG(dag_id="customoperator_test",
         description="Una dependencia",
         schedule_interval="@once",
         start_date =datetime(2022,12,6)) as dag:


    t1 = HelloOperator(task_id="hello",
                       name="alg煤n nombre")```


HelloOperator

from airflow.models.baseoperator import BaseOperator

class HelloOperator(BaseOperator):

def __init__(self, name:str, **kwargs):
    super().__init__(**kwargs)

    self.name= name

def execute(self, context):
    print(f"Hola {self.name}")

Me seria de ayuda un custom operator que en mi d铆a a d铆a realice limpieza de datos