piggy_peter_psqlop.py

import pendulum
from airflow.decorators import dag
from airflow.operators.empty import EmptyOperator
from airflow.providers.postgres.operators.postgres import PostgresOperator


@dag(schedule_interval=None, start_date=pendulum.datetime(2020, 11, 1), catchup=False)
def piggy_peter_psqlop_dag():
    start = EmptyOperator(task_id='start')
    end = EmptyOperator(task_id='end', trigger_rule='none_failed')

    task = PostgresOperator(
        task_id='piu_piu',
        postgres_conn_id='ekaterina_shrimpsizepostgres',
        sql='sql/wtf.sql',
    )
    start >> task >> end


_ = piggy_peter_psqlop_dag()

env:

pip install apache-airflow==2.8.1 --constraint "https://raw.githubusercontent.com/apache/airflow/constraints-2.8.1/constraints-3.10.txt"
pip install psycopg2-binary apache-airflow-providers-common-sql
pip install apache-airflow-providers-postgres==5.6.1

вывод от PostgresOperator в XCom самой таски

в логах вот так выглядит: