stage_customer = PostgresToHiveOperator(
    sql='select_customer.sql',
    hive_table='customer_staging',
    postgres_conn_id='postgres_oltp',
    hive_cli_conn_id='hive_staging',