2-pythonoperator.py

from airflow import DAG
from airflow.operators.python import PythonOperator 
from datetime import datetime

def print_hello():
    print("Hello gente de Platzi")

with DAG(
    dag_id="pythonoperator",
    description="Nuestro primer DAG utilizando python Operator",
    schedule_interval="@once",
    start_date=datetime(2024, 5, 8)) as dag:

    t1 = PythonOperator(task_id="hello_with_python",
                      python_callable=print_hello)
    t1