|
49 | 49 | "\n", |
50 | 50 | "import pyglove as pg\n", |
51 | 51 | "from vizier import pyglove as pg_vizier\n", |
52 | | - "from vizier.service import vizier_server" |
| 52 | + "from vizier.service import servers" |
53 | 53 | ] |
54 | 54 | }, |
55 | 55 | { |
|
136 | 136 | "id": "zIbLEGi6prpm" |
137 | 137 | }, |
138 | 138 | "source": [ |
139 | | - "Alternatively, if using a remote server, the endpoint can be specified as well:" |
| 139 | + "**Alternatively**, if using a remote server, the endpoint can be specified as well:" |
140 | 140 | ] |
141 | 141 | }, |
142 | 142 | { |
|
147 | 147 | }, |
148 | 148 | "outputs": [], |
149 | 149 | "source": [ |
150 | | - "server = vizier_server.DefaultVizierServer(host=hostname) # Normally hosted on a remote machine.\n", |
| 150 | + "server = servers.DefaultVizierServer() # Normally hosted on a remote machine.\n", |
151 | 151 | "pg_vizier.init('my_study', vizier_endpoint=server.endpoint)" |
152 | 152 | ] |
153 | 153 | }, |
|
169 | 169 | }, |
170 | 170 | "outputs": [], |
171 | 171 | "source": [ |
172 | | - "num_workers = 10\n", |
| 172 | + "NUM_WORKERS = 10\n", |
173 | 173 | "\n", |
174 | 174 | "\n", |
175 | 175 | "def work_fn(worker_id):\n", |
176 | 176 | " print(f\"Worker ID: {worker_id}\")\n", |
177 | 177 | " for value, feedback in pg.sample(\n", |
178 | 178 | " search_space,\n", |
179 | 179 | " algorithm=algorithm,\n", |
180 | | - " num_examples=num_trials // num_workers,\n", |
| 180 | + " num_examples=num_trials // NUM_WORKERS,\n", |
181 | 181 | " name=\"worker_run\",\n", |
182 | 182 | " ):\n", |
183 | 183 | " reward = evaluator(value)\n", |
|
217 | 217 | "outputs": [], |
218 | 218 | "source": [ |
219 | 219 | "with multiprocessing.pool.ThreadPool(num_workers) as pool:\n", |
220 | | - " pool.map(work_fn, range(num_workers))" |
| 220 | + " pool.map(work_fn, range(NUM_WORKERS))" |
221 | 221 | ] |
222 | 222 | }, |
223 | 223 | { |
|
238 | 238 | "outputs": [], |
239 | 239 | "source": [ |
240 | 240 | "processes = []\n", |
241 | | - "for worker_id in range(num_workers):\n", |
| 241 | + "for worker_id in range(NUM_WORKERS):\n", |
242 | 242 | " p = multiprocessing.Process(target=work_fn, args=(worker_id,))\n", |
243 | 243 | " p.start()\n", |
244 | 244 | " processes.append(p)\n", |
|
265 | 265 | "outputs": [], |
266 | 266 | "source": [ |
267 | 267 | "# Server Machine\n", |
268 | | - "server = vizier_server.DefaultVizierServer(host=hostname)" |
| 268 | + "server = servers.DefaultVizierServer()" |
269 | 269 | ] |
270 | 270 | }, |
271 | 271 | { |
|
0 commit comments