| 16 | |
| 17 | |
| 18 | class TestDiskCacheManager(DiskcacheManager): |
| 19 | def __init__(self, cache=None, cache_by=None, expire=None): |
| 20 | super().__init__(cache=cache, cache_by=cache_by, expire=expire) |
| 21 | self.running_jobs = [] |
| 22 | |
| 23 | def call_job_fn( |
| 24 | self, |
| 25 | key, |
| 26 | job_fn, |
| 27 | args, |
| 28 | context, |
| 29 | ): |
| 30 | pid = super().call_job_fn(key, job_fn, args, context) |
| 31 | self.running_jobs.append(pid) |
| 32 | return pid |
| 33 | |
| 34 | |
| 35 | def get_background_callback_manager(): |
no outgoing calls
no test coverage detected
searching dependent graphs…