()
| 246 | |
| 247 | @ray.remote(resources={"pin_worker": 1}) |
| 248 | def sum(): |
| 249 | numbers = f.remote() |
| 250 | result = 0 |
| 251 | for i, ref in enumerate(numbers): |
| 252 | result += ray.get(ref) |
| 253 | inlined = ray._private.worker.global_worker.core_worker.object_exists( |
| 254 | ref, memory_store_only=True |
| 255 | ) |
| 256 | if i < 2: |
| 257 | assert inlined |
| 258 | else: |
| 259 | assert not inlined |
| 260 | return result |
| 261 | |
| 262 | assert ray.get(sum.remote()) == 10 |
| 263 |
no test coverage detected