stage_orderinfo = PostgresToHiveOperator(
    sql='select_order_info.sql',
    hive_table='order_info_staging',
    postgres_conn_id='postgres_oltp',
    hive_cli_conn_id='hive_staging',