From c090922c4456d35e690c66503375e2b9825e72d4 Mon Sep 17 00:00:00 2001 From: Matthew Harris Date: Sun, 23 Oct 2022 10:18:35 -0400 Subject: [PATCH] DAG fix --- docker/airflow/dags/run_dot_project.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docker/airflow/dags/run_dot_project.py b/docker/airflow/dags/run_dot_project.py index 4a15e43..625f2f7 100644 --- a/docker/airflow/dags/run_dot_project.py +++ b/docker/airflow/dags/run_dot_project.py @@ -77,7 +77,7 @@ def get_object(object_name_in, earliest_date_to_sync, date_field, source_conn_in # Fail back to views if len(columns) == 0: sql_stmt = ( - "SELECT a.attname as \"column_name\"," + + "SELECT a.attname as \"column_name\"," + " pg_catalog.format_type(a.atttypid, a.atttypmod) as \"data_type\", " + " FROM pg_attribute a " + " JOIN pg_class t on a.attrelid = t.oid "