Merge pull request #73 from denhartog/master

Should address Issue #65 by compressing annotation in setup_query()
palewire · Feb 16, 2018 · 4a16cb3 · 4a16cb3
2 parents b3b45a0 + 91f3a49
commit 4a16cb3
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/postgres_copy/copy_to.py b/postgres_copy/copy_to.py
@@ -27,10 +27,11 @@ def setup_query(self):
             for field in self.query.copy_to_fields:
                 # raises error if field is not available
                 expression = self.query.resolve_ref(field)
-                if field in self.query.annotations:
-                    selection = (expression, self.compile(expression), field)
-                else:
-                    selection = (expression, self.compile(expression), None)
+                selection = (
+                    expression,
+                    self.compile(expression),
+                    field if field in self.query.annotations else None,
+                )
                 self.select.append(selection)
 
     def execute_sql(self, csv_path=None):