actually only update

jondot · Aug 14, 2017 · de7bad9 · de7bad9
1 parent ec6a19b
commit de7bad9
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pgpipeline/__init__.py b/pgpipeline/__init__.py
@@ -44,9 +44,11 @@ def process_item(self, item, spider):
                 if res is not None:
                     # remove keys with none value
                     selected = dict((k, v) for k, v in item.iteritems() if v)
-
-                self.table.upsert(
-                    selected, self.ignore_identical, types=self.types)
+                    self.table.upsert(
+                        selected, self.ignore_identical, types=self.types)
+                else:
+                    self.table.insert(
+                        selected, self.ignore_identical, types=self.types)
             else:
                 raise Exception("no such strategy: %s" % (self.onconflict))