c50ffb52761973c43aa78e876cd9159fd75f0b56,jarbas/core/management/commands/loaddatasets.py,Command,handle,#Command#,55

Before Change

        if options.get("drop", False):
            self.drop_documents()

        documents = self.selected_documents(options["start"], options["limit"])
        Document.objects.bulk_create(Document(**doc) for doc in documents)
        print("Now we have {:,} document".format(Document.objects.count()))

    def serialize(self, document):
        Read the dict generated by DictReader and fix content types

After Change

        if options.get("drop", False):
            self.drop_documents()

        source = options["source"]
        datasets = self.load_local(source) if source else self.load_remote()
        documents = self.documents_from(datasets)
        self.bulk_create_by(documents, options["batch_size"])

Instances