From 1ada4a8fefaa449784bc7e21ed50616e53e013e6 Mon Sep 17 00:00:00 2001 From: airflow Date: Wed, 22 Oct 2025 07:00:13 +0400 Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D1=82?= =?UTF-8?q?=D1=8C=20postgre-localhost-demo.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- postgre-localhost-demo.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/postgre-localhost-demo.py b/postgre-localhost-demo.py index fee6e97..dd80d8a 100644 --- a/postgre-localhost-demo.py +++ b/postgre-localhost-demo.py @@ -28,9 +28,7 @@ def save_query_to_csv(**kwargs): from airflow.providers.postgres.hooks.postgres import PostgresHook pg_hook = PostgresHook(postgres_conn_id='pg-localhost-demo') - sql = "SELECT * FROM bookings.segments s -join bookings.flights f on s.flight_id = f.flight_id -limit 100" + sql = "SELECT * FROM bookings.segments s join bookings.flights f on s.flight_id = f.flight_id limit 100" records = pg_hook.get_records(sql) columns = [desc[0] for desc in pg_hook.get_conn().cursor().description]