Airflow Oracle Operator Airflow Oracle Operator oracle oracle

Airflow Oracle Operator


You are missing a "," between the oracle_conn_id and sql argument in your DAG definition.Try:

opr_sql = OracleOperator(    task_id='task_sql',    oracle_conn_id='Oracle_schema',    sql= 'insert into table1 (a,b,c) values (1,2,3)',    autocommit ='True')