34dff626643aeab6607bd5b60516e73d5d380cdf,sacred/observers/mongo.py,MongoObserver,queued_event,#MongoObserver#Any#Any#Any#Any#Any#Any#,144

Before Change

            self.run_entry["_id"] = _id

        self.final_save(attempts=1)
        for source_name, md5 in ex_info["sources"]:
            if not self.fs.exists(filename=source_name, md5=md5):
                with open(source_name, "rb") as f:
                    self.fs.put(f, filename=source_name)

        return self.run_entry["_id"]

    def started_event(self, ex_info, command, host_info, start_time, config,
                      meta_info, _id):

After Change

        if _id is not None:
            self.run_entry["_id"] = _id
        // save sources
        self.run_entry["experiment"]["sources"] = self.save_sources(ex_info)
        self.final_save(attempts=1)
        return self.run_entry["_id"]

Instances