Upgrading arq 0.6 to 0.7
Unknown0.6.1 → 0.7
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.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
async method Drain.finish(timeout=…) - added:
async method Drain.iter(*raw_queues: bytes, pop_timeout=…) - added:
async method Drain.wait() - added:
class Drain - added:
constructor Drain(*, redis_pool: RedisPool, max_concurrent_tasks: int=…, shutdown_delay: float=…, timeout_seconds: int=…, burst_mode: bool=…, raise_task_exception: bool=…) -> None - added:
method Drain.add(coro, job, re_enqueue=…)
- changed:
class JobSerialisationError(Exception) → class JobSerialisationError(ArqError) - changed:
constructor Job(queue: str, data: bytes) -> None → constructor Job(raw_data: bytes, *, queue_name: str=…, raw_queue: bytes=…) -> None - changed:
field Job.msgpack_encoder → field Job.msgpack_encoder: Callable - changed:
field Job.msgpack_object_hook → field Job.msgpack_object_hook: Callable
- changed:
constructor Actor(*args, is_shadow=…, concurrency_enabled=…, **kwargs) → constructor Actor(*args, worker=…, concurrency_enabled=…, **kwargs) - changed:
field Actor.name → field Actor.name: str - added:
field Actor.re_enqueue_jobs
- removed:
async method BaseWorker.below_concurrency_limit() - removed:
async method BaseWorker.shutdown() - removed:
method BaseWorker.cancel_job(task, job) - removed:
method BaseWorker.job_callback(task) - removed:
method BaseWorker.schedule_job(data, queue) - changed:
async method BaseWorker.record_health(redis, redis_queues, queue_lookup) → async method BaseWorker.record_health(redis_queues, queue_lookup) - added:
field BaseWorker.drain_class - added:
field BaseWorker.jobs_complete - added:
field BaseWorker.jobs_failed - added:
field BaseWorker.jobs_timed_out - added:
field BaseWorker.repeat_health_check_logs - added:
property BaseWorker.running