Made changes to where_clause_suffix to read PostgreSQL column metadata (

#183) * Made changes to where_clause_suffix * Updated back to table_schema instead of table_name * Added new line at end of file * Removed blank space in new line
amundsen-io · Jan 24, 2020 · 84eeb29 · 84eeb29
1 parent a802501
commit 84eeb29
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/example/dags/postgres_sample_dag.py b/example/dags/postgres_sample_dag.py
@@ -75,7 +75,7 @@ def connection_string():
 def create_table_extract_job(**kwargs):
     where_clause_suffix = textwrap.dedent("""
         where table_schema in {schemas}
-    """)
+    """).format(schemas=SUPPORTED_SCHEMA_SQL_IN_CLAUSE)
 
     tmp_folder = '/var/tmp/amundsen/table_metadata'
     node_files_folder = '{tmp_folder}/nodes/'.format(tmp_folder=tmp_folder)