ApifyScheduler

{"content": ["A Scrapy scheduler that uses the Apify RequestQueue to manage requests.\n\nThis scheduler requires the asyncio Twisted reactor to be installed."]}

Index

Methods

• close
• enqueue_request
• has_pending_requests
• next_request
• open

Methods

close

• close(reason): None

• {"content": ["Close the scheduler.\n\nShut down the event loop and its thread gracefully.\n", {"

  ---

  Parameters

  • reason: str

  Returns None

enqueue_request

• enqueue_request(request): bool

• {"content": ["Add a request to the scheduler.\n\nThis could be called from either from a spider or a downloader middleware (e.g. redirect, retry, ...).\n", {"

  ---

  Parameters

  • request: Request

  Returns bool

has_pending_requests

• has_pending_requests(): bool

• {"content": ["Check if the scheduler has any pending requests.\n", {"

  ---

  Returns bool

next_request

• next_request(): Request | None

• {"content": ["Fetch the next request from the scheduler.\n", {"

  ---

  Returns Request | None

open

• open(spider): Deferred[None] | None

• {"content": ["Open the scheduler.\n", {"

  ---

  Parameters

  • spider: Spider

  Returns Deferred[None] | None