SimonBlanke /
Hyperactive
| @@ 252-285 (lines=34) @@ | ||
| 249 | assert d_time > 1.4 |
|
| 250 | ||
| 251 | ||
| 252 | def test_shared_memory_warm_start_1(): |
|
| 253 | c_time = time.perf_counter() |
|
| 254 | hyper = Hyperactive(n_processes=1) |
|
| 255 | hyper.add_search( |
|
| 256 | model, |
|
| 257 | search_space, |
|
| 258 | n_iter=300, |
|
| 259 | n_jobs=1, |
|
| 260 | ) |
|
| 261 | hyper.run() |
|
| 262 | d_time_1 = time.perf_counter() - c_time |
|
| 263 | ||
| 264 | search_data0 = hyper.search_data(model) |
|
| 265 | ||
| 266 | c_time = time.perf_counter() |
|
| 267 | hyper = Hyperactive(n_processes=1) |
|
| 268 | hyper.add_search( |
|
| 269 | model, |
|
| 270 | search_space, |
|
| 271 | n_iter=300, |
|
| 272 | n_jobs=4, |
|
| 273 | memory_warm_start=search_data0, |
|
| 274 | memory=True, |
|
| 275 | ) |
|
| 276 | hyper.run() |
|
| 277 | d_time_2 = time.perf_counter() - c_time |
|
| 278 | d_time_2 = d_time_2 / 4 |
|
| 279 | ||
| 280 | print("\n d_time_1 \n", d_time_1) |
|
| 281 | print("\n d_time_2 \n", d_time_2) |
|
| 282 | ||
| 283 | d_time = d_time_1 / d_time_2 |
|
| 284 | ||
| 285 | assert d_time > 2 |
|
| 286 | ||
| @@ 216-249 (lines=34) @@ | ||
| 213 | assert d_time < 1.3 |
|
| 214 | ||
| 215 | ||
| 216 | def test_shared_memory_warm_start_0(): |
|
| 217 | c_time = time.perf_counter() |
|
| 218 | hyper = Hyperactive(n_processes=1) |
|
| 219 | hyper.add_search( |
|
| 220 | model, |
|
| 221 | search_space, |
|
| 222 | n_iter=300, |
|
| 223 | n_jobs=1, |
|
| 224 | ) |
|
| 225 | hyper.run() |
|
| 226 | d_time_1 = time.perf_counter() - c_time |
|
| 227 | ||
| 228 | search_data0 = hyper.search_data(model) |
|
| 229 | ||
| 230 | c_time = time.perf_counter() |
|
| 231 | hyper = Hyperactive(n_processes=1) |
|
| 232 | hyper.add_search( |
|
| 233 | model, |
|
| 234 | search_space, |
|
| 235 | n_iter=300, |
|
| 236 | n_jobs=4, |
|
| 237 | memory_warm_start=search_data0, |
|
| 238 | memory="share", |
|
| 239 | ) |
|
| 240 | hyper.run() |
|
| 241 | d_time_2 = time.perf_counter() - c_time |
|
| 242 | d_time_2 = d_time_2 / 4 |
|
| 243 | ||
| 244 | print("\n d_time_1 \n", d_time_1) |
|
| 245 | print("\n d_time_2 \n", d_time_2) |
|
| 246 | ||
| 247 | d_time = d_time_1 / d_time_2 |
|
| 248 | ||
| 249 | assert d_time > 1.4 |
|
| 250 | ||
| 251 | ||
| 252 | def test_shared_memory_warm_start_1(): |
|
| @@ 71-104 (lines=34) @@ | ||
| 68 | assert d_time > 1.4 |
|
| 69 | ||
| 70 | ||
| 71 | def test_shared_memory_1(): |
|
| 72 | c_time = time.perf_counter() |
|
| 73 | hyper = Hyperactive(n_processes=1) |
|
| 74 | hyper.add_search( |
|
| 75 | model, |
|
| 76 | search_space, |
|
| 77 | n_iter=300, |
|
| 78 | n_jobs=1, |
|
| 79 | memory=True, |
|
| 80 | ) |
|
| 81 | hyper.run() |
|
| 82 | d_time_1 = time.perf_counter() - c_time |
|
| 83 | ||
| 84 | n_jobs = 4 |
|
| 85 | c_time = time.perf_counter() |
|
| 86 | hyper = Hyperactive(n_processes=1) |
|
| 87 | hyper.add_search( |
|
| 88 | model, |
|
| 89 | search_space, |
|
| 90 | n_iter=300, |
|
| 91 | n_jobs=n_jobs, |
|
| 92 | memory=True, |
|
| 93 | ) |
|
| 94 | hyper.run() |
|
| 95 | d_time_2 = time.perf_counter() - c_time |
|
| 96 | d_time_2 = d_time_2 / n_jobs |
|
| 97 | ||
| 98 | print("\n d_time_1 \n", d_time_1) |
|
| 99 | print("\n d_time_2 \n", d_time_2) |
|
| 100 | ||
| 101 | d_time = d_time_1 / d_time_2 |
|
| 102 | ||
| 103 | assert d_time > 0.7 |
|
| 104 | assert d_time < 1.3 |
|
| 105 | ||
| 106 | ||
| 107 | def test_shared_memory_2(): |
|
| @@ 36-68 (lines=33) @@ | ||
| 33 | } |
|
| 34 | ||
| 35 | ||
| 36 | def test_shared_memory_0(): |
|
| 37 | c_time = time.perf_counter() |
|
| 38 | hyper = Hyperactive(n_processes=1) |
|
| 39 | hyper.add_search( |
|
| 40 | model, |
|
| 41 | search_space, |
|
| 42 | n_iter=300, |
|
| 43 | n_jobs=1, |
|
| 44 | memory="share", |
|
| 45 | ) |
|
| 46 | hyper.run() |
|
| 47 | d_time_1 = time.perf_counter() - c_time |
|
| 48 | ||
| 49 | n_jobs = 4 |
|
| 50 | c_time = time.perf_counter() |
|
| 51 | hyper = Hyperactive(n_processes=1) |
|
| 52 | hyper.add_search( |
|
| 53 | model, |
|
| 54 | search_space, |
|
| 55 | n_iter=300, |
|
| 56 | n_jobs=n_jobs, |
|
| 57 | memory="share", |
|
| 58 | ) |
|
| 59 | hyper.run() |
|
| 60 | d_time_2 = time.perf_counter() - c_time |
|
| 61 | d_time_2 = d_time_2 / n_jobs |
|
| 62 | ||
| 63 | print("\n d_time_1 \n", d_time_1) |
|
| 64 | print("\n d_time_2 \n", d_time_2) |
|
| 65 | ||
| 66 | d_time = d_time_1 / d_time_2 |
|
| 67 | ||
| 68 | assert d_time > 1.4 |
|
| 69 | ||
| 70 | ||
| 71 | def test_shared_memory_1(): |
|
