Upgrading arq 0.16 to 0.17
Unknown0.16.1 → 0.17.1
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.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- changed:
async function create_pool(settings: RedisSettings=…, *, _retry: int=…) -> ArqRedis → async function create_pool(settings: RedisSettings=…, *, retry: int=…, job_serializer: Optional[Serializer]=…, job_deserializer: Optional[Deserializer]=…) -> ArqRedis - added:
async method ArqRedis.queued_jobs(*, queue_name: str=…) -> List[JobDef] - added:
constructor ArqRedis(pool_or_conn, job_serializer: Optional[Serializer]=…, job_deserializer: Optional[Deserializer]=…, **kwargs) -> None
- removed:
class PickleError(RuntimeError) - removed:
function pickle_job(function_name: str, args: tuple, kwargs: dict, job_try: int, enqueue_time_ms: int) - removed:
function pickle_result(function: str, args: tuple, kwargs: dict, job_try: int, enqueue_time_ms: int, success: bool, result: Any, start_ms: int, finished_ms: int, ref: str) -> Optional[bytes] - removed:
function unpickle_job(r: bytes) -> JobDef - removed:
function unpickle_job_raw(r: bytes) -> tuple - removed:
function unpickle_result(r: bytes) -> JobResult - changed:
constructor Job(job_id: str, redis, _queue_name: str=…) → constructor Job(job_id: str, redis, _queue_name: str=…, _deserializer: Optional[Deserializer]=…) - added:
class DeserializationError(SerializationError) - added:
class SerializationError(RuntimeError) - added:
function deserialize_job(r: bytes, *, deserializer: Optional[Deserializer]=…) -> JobDef - added:
function deserialize_job_raw(r: bytes, *, deserializer: Optional[Deserializer]=…) -> tuple - added:
function deserialize_result(r: bytes, *, deserializer: Optional[Deserializer]=…) -> JobResult - added:
function serialize_job(function_name: str, args: tuple, kwargs: dict, job_try: int, enqueue_time_ms: int, *, serializer: Optional[Serializer]=…) -> Optional[bytes] - added:
function serialize_result(function: str, args: tuple, kwargs: dict, job_try: int, enqueue_time_ms: int, success: bool, result: Any, start_ms: int, finished_ms: int, ref: str, *, serializer: Optional[Serializer]=…) -> Optional[bytes] - added:
variable Deserializer - added:
variable Serializer
- changed:
async method Worker.abort_job(job_id: str, result_data: bytes) → async method Worker.abort_job(job_id: str, result_data: Optional[bytes]) - changed:
constructor Worker(functions: Sequence[Function]=…, *, queue_name: str=…, cron_jobs: Optional[Sequence[CronJob]]=…, redis_settings: RedisSettings=…, redis_pool: ArqRedis=…, burst: bool=…, on_startup: Callable[[Dict], Awaitable]=…, on_shutdown: Callable[[Dict], Awaitable]=…, max_jobs: int=…, job_timeout: SecondsTimedelta=…, keep_result: SecondsTimedelta=…, poll_delay: SecondsTimedelta=…, max_tries… → constructor Worker(functions: Sequence[Function]=…, *, queue_name: str=…, cron_jobs: Optional[Sequence[CronJob]]=…, redis_settings: RedisSettings=…, redis_pool: ArqRedis=…, burst: bool=…, on_startup: Callable[[Dict], Awaitable]=…, on_shutdown: Callable[[Dict], Awaitable]=…, max_jobs: int=…, job_timeout: SecondsTimedelta=…, keep_result: SecondsTimedelta=…, poll_delay: SecondsTimedelta=…, queue_rea…