import multiprocessing
import wandb
def run_experiment(params):
# wandb.init で実験を開始
with wandb.init(config=params):
# 実験を実行
pass
if __name__ == "__main__":
# バックエンドを開始し、グローバル設定を行う
wandb.setup(settings={"project": "my_project"})
# 実験パラメータを定義
experiment_params = [
{"learning_rate": 0.01, "epochs": 10},
{"learning_rate": 0.001, "epochs": 20},
]
# 複数のプロセスを開始し、それぞれで個別の実験を実行
processes = []
for params in experiment_params:
p = multiprocessing.Process(target=run_experiment, args=(params,))
p.start()
processes.append(p)
# すべてのプロセスが完了するのを待機
for p in processes:
p.join()
# オプション: 明示的にバックエンドを終了する
wandb.teardown()