Update s3_to_redshift.py

airflow-plugins · Feb 26, 2018 · 6623b71 · 6623b71
1 parent f4b7a40
commit 6623b71
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/operators/s3_to_redshift.py b/operators/s3_to_redshift.py
@@ -140,7 +140,7 @@ def __init__(self,
  if not (isinstance(self.foreign_key, dict) or isinstance(self.foreign_key, list)):
  raise Exception('Foreign Keys must be specified as either a dictionary or a list of dictionaries.')
 
- if ((',' in self.distkey) or not isinstance(self.distkey, str)):
+ if self.distkey and ((',' in self.distkey) or not isinstance(self.distkey, str)):
  raise Exception('Only one distribution key may be specified.')
 
  if self.sort_type.lower() not in ('compound', 'interleaved'):