13986978d4545aa429a7fc233d8e39718d52e255,studio/keyvalue_provider.py,KeyValueProvider,checkpoint_experiment,#KeyValueProvider#Any#Any#,223

Before Change

        self._delete(self._get_experiments_keybase() + experiment_key)

    def checkpoint_experiment(self, experiment, blocking=False):
        if not isinstance(experiment, six.string_types):
            key = experiment.key
        else:
            key = experiment

        self.logger.debug(("checkpointing {}".format(
            self._get_experiments_keybase() + key)))

        experiment_dict = self._get(self._get_experiments_keybase() + key)

After Change

        experiment_dict = self._get(self._get_experiments_keybase() + key)

        workers = []
        with ThreadPoolExecutor(max_workers=8) as executor:
            for _, art in six.iteritems(experiment.artifacts):
                if art["mutable"] and art.get("local"):
                    workers.append(executor.submit(self.store.put_artifact, art))
            wait(workers)

        for worker in workers:
            try:

Instances