tilearray.fetch.FetchPolicy#

class tilearray.fetch.FetchPolicy(max_concurrent=3, max_connections=None, retries=3, timeout=30.0, rate_limit_per_second=2.0, rate_limiter=None, adaptive_concurrency=False, initial_concurrent=2, min_concurrent=1, multiplicative_decrease=0.5, additive_increase=2, forbidden_circuit_breaker=False, forbidden_window_seconds=5.0, forbidden_threshold=6, forbidden_cooldown_seconds=15.0, pressure_classifier=None)[source]#

Configuration for TileFetcher.

Parameters:

  • max_concurrent (int)

  • max_connections (int | None)

  • retries (int)

  • timeout (float)

  • rate_limit_per_second (float | None)

  • rate_limiter (HostRateLimiter | None)

  • adaptive_concurrency (bool)

  • initial_concurrent (int)

  • min_concurrent (int)

  • multiplicative_decrease (float)

  • additive_increase (int)

  • forbidden_circuit_breaker (bool)

  • forbidden_window_seconds (float)

  • forbidden_threshold (int)

  • forbidden_cooldown_seconds (float)

  • pressure_classifier (PressureClassifier | None)

__init__(max_concurrent=3, max_connections=None, retries=3, timeout=30.0, rate_limit_per_second=2.0, rate_limiter=None, adaptive_concurrency=False, initial_concurrent=2, min_concurrent=1, multiplicative_decrease=0.5, additive_increase=2, forbidden_circuit_breaker=False, forbidden_window_seconds=5.0, forbidden_threshold=6, forbidden_cooldown_seconds=15.0, pressure_classifier=None)#
Parameters:

  • max_concurrent (int)

  • max_connections (int | None)

  • retries (int)

  • timeout (float)

  • rate_limit_per_second (float | None)

  • rate_limiter (HostRateLimiter | None)

  • adaptive_concurrency (bool)

  • initial_concurrent (int)

  • min_concurrent (int)

  • multiplicative_decrease (float)

  • additive_increase (int)

  • forbidden_circuit_breaker (bool)

  • forbidden_window_seconds (float)

  • forbidden_threshold (int)

  • forbidden_cooldown_seconds (float)

  • pressure_classifier (PressureClassifier | None)

Return type:

None

Methods

__init__([max_concurrent, max_connections, ...])

cache_key()

Hashable key for sharing fetcher instances.

Attributes

adaptive_concurrency

additive_increase

forbidden_circuit_breaker

forbidden_cooldown_seconds

forbidden_threshold

forbidden_window_seconds

initial_concurrent

max_concurrent

max_connections

min_concurrent

multiplicative_decrease

pressure_classifier

rate_limit_per_second

rate_limiter

retries

timeout