(num)
| 360 | cvar = contextvars.ContextVar('cvar') |
| 361 | |
| 362 | def sub(num): |
| 363 | for i in range(10): |
| 364 | cvar.set(num + i) |
| 365 | time.sleep(random.uniform(0.001, 0.05)) |
| 366 | self.assertEqual(cvar.get(), num + i) |
| 367 | return num |
| 368 | |
| 369 | tp = concurrent.futures.ThreadPoolExecutor(max_workers=10) |
| 370 | try: |
no test coverage detected