Skip to content

Commit 0f96ebd

Browse files
Reverted left over changes that had overwritten the previous linting of this file.
1 parent 7380bee commit 0f96ebd

1 file changed

Lines changed: 4 additions & 5 deletions

File tree

docker/airflow/dags/run_dot_project.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ def save_object(
220220
using = f"USING {col}::{type}"
221221
query = f"ALTER TABLE {schema}.{object_name_in} ALTER COLUMN {col} TYPE {type} {using};"
222222
with PostgresHook(
223-
postgres_conn_id=target_conn_in, schema=target_conn_in
223+
postgres_conn_id=target_conn_in, schema=target_conn_in
224224
).get_conn() as conn:
225225
cur = conn.cursor()
226226
print(query)
@@ -272,10 +272,9 @@ def sync_object(
272272
def drop_tables_in_dot_tests_schema(target_conn_in, schema_to_drop_from):
273273
"""
274274
We are syncing new data where new columns and columns types might change.
275-
Postgres will prevent ALTER TABLE if any views exist, so we will drop all
276-
tables in the dot test schema. These will be recreated in the dot run.
277-
This assumes the dot tests schema is dot_data_tests
278-
(defined as variable "schema_to_drop_from").
275+
Postgres will prevent ALTER TABLE if any views exist, so we will drop all tables in the dot test schema.
276+
These will be recreated in the dot run.
277+
This assumes the dot tests schema is dot_data_tests (defined as variable "schema_to_drop_from").
279278
280279
Input
281280
-----

0 commit comments

Comments
 (0)