Delayed initialization. At context creation time we have no access to the below described parameters. Args: num_workers: Number of worker processes to run in parallel. heartbeat_timeout: Timeout in seconds for waiting for results. Each time the timeout is reached,
(self, num_workers, heartbeat_timeout=1, notify_function=None)
| 143 | self.abort_now = False |
| 144 | |
| 145 | def init(self, num_workers, heartbeat_timeout=1, notify_function=None): |
| 146 | """ |
| 147 | Delayed initialization. At context creation time we have no access to the |
| 148 | below described parameters. |
| 149 | Args: |
| 150 | num_workers: Number of worker processes to run in parallel. |
| 151 | heartbeat_timeout: Timeout in seconds for waiting for results. Each time |
| 152 | the timeout is reached, a heartbeat is signalled and timeout is reset. |
| 153 | notify_function: Callable called to signal some events like termination. The |
| 154 | event name is passed as string. |
| 155 | """ |
| 156 | pass |
| 157 | |
| 158 | def add_jobs(self, jobs): |
| 159 | pass |
no outgoing calls
no test coverage detected