diff --git a/user1/testpostgre.py b/user1/testpostgre.py new file mode 100644 index 0000000..07bd8bb --- /dev/null +++ b/user1/testpostgre.py @@ -0,0 +1,7 @@ +from airflow.providers.postgres.operators.postgres import PostgresOperator + +task = PostgresOperator( + task_id='test_query', + postgres_conn_id='my_postgres', + sql='SELECT 1;' +)