Skip to content

Upgrading arq 0.22 to 0.23

Unknown0.22 → 0.23

Full comparisonBack to arq
Fetching 2 releases from GitHub…0 / 2
UnknownUpgrade verdict

DepDelta is still reading the notes for this range, 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.

Adds redis >=4.2.0rc2.

Drops aioredis.

Installs 7 packages in all (was 9).

No longer installs async-timeout, hiredis.

API changes

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

  • changed: constructor ArqRedis(pool_or_conn: Any, job_serializer: Optional[Serializer]=…, job_deserializer: Optional[Deserializer]=…, default_queue_name: str=…, **kwargs: Any) -> None → constructor ArqRedis(pool_or_conn: Optional[ConnectionPool]=…, job_serializer: Optional[Serializer]=…, job_deserializer: Optional[Deserializer]=…, default_queue_name: str=…, **kwargs: Any) -> None
  • changed: function cron(coroutine: Union[str, WorkerCoroutine], *, name: Optional[str]=…, month: OptionType=…, day: OptionType=…, weekday: WeekdayOptionType=…, hour: OptionType=…, minute: OptionType=…, second: OptionType=…, microsecond: int=…, run_at_startup: bool=…, unique: bool=…, timeout: Optional[SecondsTimedelta]=…, keep_result: Optional[float]=…, keep_result_forever: Optional[bool]=…, max_tries: Opti… → function cron(coroutine: Union[str, WorkerCoroutine], *, name: Optional[str]=…, month: OptionType=…, day: OptionType=…, weekday: WeekdayOptionType=…, hour: OptionType=…, minute: OptionType=…, second: OptionType=…, microsecond: int=…, run_at_startup: bool=…, unique: bool=…, job_id: Optional[str]=…, timeout: Optional[SecondsTimedelta]=…, keep_result: Optional[float]=…, keep_result_forever: Optional…
  • added: field CronJob.job_id: Optional[str]
  • 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]=…) -> Optional[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: async method Worker.start_jobs(job_ids: List[str]) -> None → async method Worker.start_jobs(job_ids: List[bytes]) -> None
  • 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]=…, handle_signals: bool=…, max_jobs: int=…, job_timeout: SecondsTimedelta=…, keep_result: Seconds… → 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]=…, handle_sig…