(num)
| 380 | cvar = contextvars.ContextVar('cvar') |
| 381 | |
| 382 | def sub(num): |
| 383 | for i in range(10): |
| 384 | cvar.set(num + i) |
| 385 | time.sleep(random.uniform(0.001, 0.05)) |
| 386 | self.assertEqual(cvar.get(), num + i) |
| 387 | return num |
| 388 | |
| 389 | tp = concurrent.futures.ThreadPoolExecutor(max_workers=10) |
| 390 | try: |
no test coverage detected