Skip to content

Upgrading arq 0.26 to 0.27

Breaking0.26.3 → 0.27.0Platform1Fixed2Other3

Full comparisonBack to arq
BreakingUpgrade verdict

A platform requirement change.

In plain terms
  • The package now officially works with Python 3.13, and Python 3.8 is no longer listed as supported.
Must act 1 item needs code or config changes

Python requirement changed in 0.27.0: >=3.8 → >=3.9.

What you must change

Platform1
Adds support for Python 3.13 and removes advertised support for Python 3.8.
0.27.0GitHub ReleaseSummarizedView source

API changes

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

  • changed: async method ArqRedis.all_job_results() -> List[JobResult] → async method ArqRedis.all_job_results() -> list[JobResult]
  • changed: async method ArqRedis.queued_jobs(*, queue_name: Optional[str]=…) -> List[JobDef] → async method ArqRedis.queued_jobs(*, queue_name: Optional[str]=…) -> list[JobDef]
  • changed: field RedisSettings.host: Union[str, List[Tuple[str, int]]] → field RedisSettings.host: Union[str, list[tuple[str, int]]]
  • changed: field RedisSettings.retry_on_error: Optional[List[Exception]] → field RedisSettings.retry_on_error: Optional[list[type[Exception]]]
  • changed: field JobDef.args: Tuple[Any, ...] → field JobDef.args: tuple[Any, ...]
  • changed: field JobDef.kwargs: Dict[str, Any] → field JobDef.kwargs: dict[str, Any]
  • changed: function deserialize_job_raw(r: bytes, *, deserializer: Optional[Deserializer]=…) -> Tuple[str, Tuple[Any, ...], Dict[str, Any], int, int] → function deserialize_job_raw(r: bytes, *, deserializer: Optional[Deserializer]=…) -> tuple[str, tuple[Any, ...], dict[str, Any], int, int]
  • changed: function serialize_job(function_name: str, args: Tuple[Any, ...], kwargs: Dict[str, Any], job_try: Optional[int], enqueue_time_ms: int, *, serializer: Optional[Serializer]=…) -> bytes → function serialize_job(function_name: str, args: tuple[Any, ...], kwargs: dict[str, Any], job_try: Optional[int], enqueue_time_ms: int, *, serializer: Optional[Serializer]=…) -> bytes
  • 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, job_id: 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]
  • changed: function default_log_config(verbose: bool) -> Dict[str, Any] → function default_log_config(verbose: bool) -> dict[str, Any]
  • changed: function args_to_string(args: Sequence[Any], kwargs: Dict[str, Any]) -> str → function args_to_string(args: Sequence[Any], kwargs: dict[str, Any]) -> str
  • changed: async method Worker.start_jobs(job_ids: List[bytes]) -> None → async method Worker.start_jobs(job_ids: list[bytes]) -> None
  • changed: constructor FailedJobs(count: int, job_results: List[JobResult]) → constructor FailedJobs(count: int, job_results: list[JobResult])
  • changed: function get_kwargs(settings_cls: WorkerSettingsType) -> Dict[str, NameError] → function get_kwargs(settings_cls: WorkerSettingsType) -> dict[str, NameError]