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

Before Change

            entry_dict.update(val)

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

    def update(self, **kwargs):

After Change

        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,
                    collection=self.feed_type.lower(),
                    doc=item,
                )
            )

    def update(self, **kwargs):
        self.logger.info("VIA4 database update started")

Instances