Method
__init__
(self,
task: Callable[..., bool],
error_queue: Queue,
name: Optional[str] = None,
stop_event: Optional[threading.Event] = None,
**kwargs)
Source from the content-addressed store, hash-verified
| 295 | """ |
| 296 | |
| 297 | def __init__(self, |
| 298 | task: Callable[..., bool], |
| 299 | error_queue: Queue, |
| 300 | name: Optional[str] = None, |
| 301 | stop_event: Optional[threading.Event] = None, |
| 302 | **kwargs): |
| 303 | super().__init__(name=name) |
| 304 | self.task = task |
| 305 | self.error_queue = error_queue |
| 306 | self.kwargs = kwargs |
| 307 | self.daemon = True |
| 308 | self.stop_event = stop_event or threading.Event() |
| 309 | |
| 310 | def run(self): |
| 311 | |
Callers
nothing calls this directly
Tested by
no test coverage detected