diff --git a/tap_postgres/db.py b/tap_postgres/db.py index c7711c42..b36fd922 100644 --- a/tap_postgres/db.py +++ b/tap_postgres/db.py @@ -49,6 +49,8 @@ def open_connection(conn_config, logical_replication=False): 'connect_timeout': 30 } + cfg['options'] = ' '.join(map('-c {0}'.format, conn_config.get('options',[]))) + if conn_config.get('sslmode'): cfg['sslmode'] = conn_config['sslmode']