From 008ae6edf96c6aa181945b2a251b22ce300b4970 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Tue, 5 Nov 2019 16:05:06 -0600 Subject: [PATCH] bug fix with mongodb --- transport/mongo.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/transport/mongo.py b/transport/mongo.py index 3854206..e363008 100644 --- a/transport/mongo.py +++ b/transport/mongo.py @@ -65,8 +65,10 @@ class MongoWriter(Mongo,Writer): def write(self,**args): # document = self.db[self.uid].find() collection = self.db[self.uid] - collection.update_one() - self.db[self.uid].insert_one(args['row']) + if type(args['row']) == list : + self.db[self.uid].insert_many(args['row']) + else: + self.db[self.uid].insert_one(args['row']) def set(self,document): collection = self.db[self.uid] if collection.count_document() > 0 :