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 "