Permalink
Browse files

Removed config.redshift usage inside redshift_database class.

  • Loading branch information...
1 parent 3e73b2a commit 8cc148dd701e0e144904c56c5f6888d9cef62f8d @eldhosejohn eldhosejohn committed Aug 9, 2016
Showing with 4 additions and 3 deletions.
  1. +4 −3 dataduct/pipeline/redshift_database.py
@@ -55,8 +55,9 @@ def __init__(self,
'*password': password
}
- if 'CLUSTER_ID' in config.redshift:
- kwargs['clusterId'] = config.redshift['CLUSTER_ID']
+ if CLUSTER_ID:
+ kwargs['clusterId'] = CLUSTER_ID
else:
- kwargs['connectionString'] = config.redshift['CONNECTION_STRING']
+ kwargs['connectionString'] = CONNECTION_STRING
+
super(RedshiftDatabase, self).__init__(**kwargs)

0 comments on commit 8cc148d

Please sign in to comment.