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')