easy5 pts · first answer countsairflowairflow-hooksairflow-taskflow

Querying Postgres inside a @task

Inside a @task function you need the rows of a small query on the warehouse connection "dw". What is the usual approach?

A.Read the password from airflow.cfg and connectB.Use PostgresHook(postgres_conn_id="dw").get_records(sql)C.Call PostgresOperator inside the functionD.Pull the rows from the metadata database

Discussion 0

Join free to post in the discussion.

Querying Postgres inside a @task

Discussion 0

Related questions