Skip to content

Upgrading arq 0.25 to 0.26

Unknown0.25.0 → 0.26.3Changed6Fixed1Other1

Full comparisonBack to arq
Fetching 4 releases from GitHub…3 / 4
UnknownUpgrade verdict

DepDelta is still reading the notes for 1 of 4 releases, so breaking changes can't be ruled out yet.

In plain terms
  • DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
  • This page updates as the notes come in.
Must act Still reading release notes

DepDelta is still reading the release notes in this range. This updates as they come in.

Python requirement changed in 0.26.0b1: >=3.7 → >=3.8.

Drops typing-extensions.

Also installs pyjwt.

Moves redis 8.1.0 → 5.3.1. Your build may pick other versions.

API changes

Generated by DepDelta from published Python source. Not mixed with prose notes.

  • changed: async function create_pool(settings_: RedisSettings=…, *, retry: int=…, job_serializer: Optional[Serializer]=…, job_deserializer: Optional[Deserializer]=…, default_queue_name: str=…, expires_extra_ms: int=…) -> ArqRedis → async function create_pool(settings_: Optional[RedisSettings]=…, *, retry: int=…, job_serializer: Optional[Serializer]=…, job_deserializer: Optional[Deserializer]=…, default_queue_name: str=…, expires_extra_ms: int=…) -> ArqRedis
  • changed: async method ArqRedis.queued_jobs(*, queue_name: str=…) -> List[JobDef] → async method ArqRedis.queued_jobs(*, queue_name: Optional[str]=…) -> List[JobDef]
  • added: field RedisSettings.max_connections: Optional[int]
  • added: field RedisSettings.retry: Optional[Retry]
  • added: field RedisSettings.retry_on_error: Optional[List[Exception]]
  • added: field RedisSettings.retry_on_timeout: bool
  • removed: field JobResult.job_id: Optional[str]
  • changed: async method Job.result(timeout: Optional[float]=…, *, poll_delay: float=…, pole_delay: float=…) -> Any → async method Job.result(timeout: Optional[float]=…, *, poll_delay: float=…, pole_delay: Optional[float]=…) -> Any
  • changed: function serialize_result(function: str, args: Tuple[Any, ...], kwargs: Dict[str, Any], job_try: int, enqueue_time_ms: int, success: bool, result: Any, start_ms: int, finished_ms: int, ref: str, queue_name: str, *, serializer: Optional[Serializer]=…) -> Optional[bytes] → function serialize_result(function: str, args: Tuple[Any, ...], kwargs: Dict[str, Any], job_try: int, enqueue_time_ms: int, success: bool, result: Any, start_ms: int, finished_ms: int, ref: str, queue_name: str, job_id: str, *, serializer: Optional[Serializer]=…) -> Optional[bytes]
  • added: field JobDef.job_id: Optional[str]
  • changed: constructor Worker(functions: Sequence[Union[Function, WorkerCoroutine]]=…, *, queue_name: Optional[str]=…, cron_jobs: Optional[Sequence[CronJob]]=…, redis_settings: RedisSettings=…, redis_pool: ArqRedis=…, burst: bool=…, on_startup: Optional[StartupShutdown]=…, on_shutdown: Optional[StartupShutdown]=…, on_job_start: Optional[StartupShutdown]=…, on_job_end: Optional[StartupShutdown]=…, after_job_… → constructor Worker(functions: Sequence[Union[Function, WorkerCoroutine]]=…, *, queue_name: Optional[str]=…, cron_jobs: Optional[Sequence[CronJob]]=…, redis_settings: Optional[RedisSettings]=…, redis_pool: Optional[ArqRedis]=…, burst: bool=…, on_startup: Optional[StartupShutdown]=…, on_shutdown: Optional[StartupShutdown]=…, on_job_start: Optional[StartupShutdown]=…, on_job_end: Optional[StartupShu…