Upgrading arq 0.19 to 0.20
Unknown0.19.1 → 0.20
Fetching 1 release from GitHub…0 / 1
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.
Drops async-timeout.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
variable abort_job_max_age - added:
variable abort_jobs_ss - added:
variable keep_cronjob_progress
- removed:
method CronJob.set_next(dt: datetime) -> 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]=…, max_tries: Optional[int]=…) -> CronJob → 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… - added:
field CronJob.keep_result_forever: Optional[bool] - added:
method CronJob.calculate_next(prev_run: datetime) -> None
- changed:
async method Job.result(timeout: Optional[float]=…, *, pole_delay: float=…) -> Any → async method Job.result(timeout: Optional[float]=…, *, poll_delay: float=…, pole_delay: 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, *, 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, *, serializer: Optional[Serializer]=…) -> Optional[bytes] - added:
async method Job.abort(*, timeout: Optional[float]=…, poll_delay: float=…) -> bool - added:
field JobResult.queue_name: str
- removed:
async method Worker.abort_job(job_id: str, result_data: Optional[bytes]) -> None - changed:
async method Worker.finish_job(job_id: str, finish: bool, result_data: Optional[bytes], result_timeout_s: Optional[float], incr_score: Optional[int]) -> None → async method Worker.finish_job(job_id: str, finish: bool, result_data: Optional[bytes], result_timeout_s: Optional[float], keep_result_forever: bool, incr_score: Optional[int], keep_in_progress: Optional[float]) -> None - changed:
async method Worker.run_cron() -> None → async method Worker.run_cron(n: datetime, delay: float, num_windows: int=…) -> None - changed:
function func(coroutine: Union[str, Function, WorkerCoroutine], *, name: Optional[str]=…, keep_result: Optional[SecondsTimedelta]=…, timeout: Optional[SecondsTimedelta]=…, max_tries: Optional[int]=…) -> Function → function func(coroutine: Union[str, Function, WorkerCoroutine], *, name: Optional[str]=…, keep_result: Optional[SecondsTimedelta]=…, timeout: Optional[SecondsTimedelta]=…, keep_result_forever: Optional[bool]=…, max_tries: Optional[int]=…) -> Function - added:
async method Worker.finish_failed_job(job_id: str, result_data: Optional[bytes]) -> None - added:
field Function.keep_result_forever: Optional[bool]