grab.spider.service.task_dispatcher
¶
Module Contents¶
Classes¶
- class grab.spider.service.task_dispatcher.TaskDispatcherService(fatal_error_queue: queue.Queue[grab.spider.interface.FatalErrorQueueItem], process_service_result: collections.abc.Callable[[Any, grab.spider.task.Task, None | dict[str, Any]], Any])[source]¶
Bases:
grab.spider.service.base.BaseService
- worker_callback(worker: grab.spider.service.base.ServiceWorker) None [source]¶