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

Before Change

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

        checkpoint_threads = [
            Thread(
                target=self.store.put_artifact,
                args=(art,))
            for _, art in six.iteritems(experiment.artifacts)
            if art["mutable"] and art.get("local")]

        for t in checkpoint_threads:
            t.start()

After Change

        for worker in workers:
            try:
                worker.result()
            except Exception as exc:
                // If any of artifact savers failed and threw an exception,
                // rethrow it to signal overall checkpoint failure
                raise exc

Instances