Python Operator

This is wonderful!

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

from datetime import datetime


def print_hello():
    print('Hello people from python funtion')

with DAG(
    dag_id='python_operator',
    description='Fisrt dag using python operator',
    schedule_interval='@once',
    start_date=datetime(2022,8,1)
    ) as dag:
    
    t1 = PythonOperator(
        task_id = 'hello_with_python',
        python_callable = print_hello
    )
    ```

Me gusta la parte de que se se sigan podiendo reutilizar funciones, dejo ejemplo

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

def print_hello(country, **kwargs):
    print(f'I am processing this {country}')


with DAG(dag_id='pythonoperator'
        , description='Utilizando python operator'
        , start_date=datetime(2023, 6, 7)
        , schedule_interval='@once') as dag:


    t1 = PythonOperator(task_id='process_ar'
                        , python_callable=print_hello
                        , op_kwargs={'country':'AR'})

    t2 = PythonOperator(task_id='process_uy'
                        , python_callable=print_hello
                        , op_kwargs={'country':'UY'})

    t1 >> t2 

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

def print_hello():
    print("HELLO PAPUS")

with DAG(dag_id="pythonoperator",
         description="Nuestro primer DAG utilizando python ope",
         schedule_interval="@once",
         start_date =datetime(2022,12,6)) as dag:


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

    t1                        ```

😃

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


def print_hello():
    return print('hello world with python in airflow')


with DAG(dag_id='primer_dag_python',
         schedule_interval='@once',
         start_date=datetime(2022, 7, 1)) as dag:

    t1 = PythonOperator(task_id='primer_task_python',
                        python_callable=print_hello)

Ahora con Python Operator:

Holis from python operator!!