Код-ревью: DAG ежедневной выгрузки заказов

from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.python import PythonOperator
import psycopg2, pandas as pd

conn = psycopg2.connect("host=prod-db user=etl password=Qwerty123")
TABLES = pd.read_sql("select table_name from etl_tables", conn)

def load_orders(**ctx):
    day = (datetime.now() - timedelta(days=1)).date()
    df = pd.read_sql(f"select * from orders where created_at::date = '{day}'", conn)
    dwh.execute("insert into dwh.orders select * from df")

with DAG("orders", start_date=datetime.now(), schedule="@daily") as dag:
    PythonOperator(task_id="load", python_callable=load_orders)