stage_product = PostgresToHiveOperator(
    sql='select_product.sql',
    hive_table='product_staging',
    postgres_conn_id='postgres_oltp',
    hive_cli_conn_id='hive_staging',