b8ce0940159022a61a2709e615dade45b53f97ef,sbin/db_mgmt_ref.py,VIADownloads,process_item,#VIADownloads#Any#,73

Before Change

        entry_dict = {}

        for key, val in item.items():
            entry_dict = {"id": key}
            entry_dict.update(val)

        if self.is_update:
            return UpdateOne({"id": key}, {"$set": entry_dict}, upsert=True, )
        else:
            return InsertOne(entry_dict)

After Change

    def process_item(self, item):

        if self.is_update:
            self.queue.put(
                DatabaseAction(
                    action=DatabaseAction.actions.UpdateOne,
                    collection=self.feed_type.lower(),
                    doc=item,
                )
            )
        else:
            self.queue.put(
                DatabaseAction(
                    action=DatabaseAction.actions.InsertOne,

Instances