Upgrading kombu 2 to 3
Unknown2.5.16 → 3.0.37
Fetching 38 releases from GitHub…0 / 38
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 amqp >= 1.4.9,<2.0, anyjson >= 0.3.3.
Installs 2 packages in all (was 0).
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- removed:
class no_install(install) - removed:
method no_install.run(*args, **kwargs)
- removed:
class TransportCase(unittest.TestCase) - removed:
field TransportCase.connected - removed:
field TransportCase.connection_options - removed:
field TransportCase.event_loop_max - removed:
field TransportCase.message_size_limit - removed:
field TransportCase.password - removed:
field TransportCase.prefix - removed:
field TransportCase.reliable_purge - removed:
field TransportCase.sep - removed:
field TransportCase.skip_test_reason - removed:
field TransportCase.suppress_disorder_warning - removed:
field TransportCase.transport - removed:
field TransportCase.userid - removed:
function consumeN(conn, consumer, n=…, timeout=…) - removed:
function say(msg) - removed:
method TransportCase.P(rest) - removed:
method TransportCase.after_connect(connection) - removed:
method TransportCase.before_connect() - removed:
method TransportCase.do_connect() - removed:
method TransportCase.get_connection(**options) - removed:
method TransportCase.purge(names) - removed:
method TransportCase.purge_consumer(consumer) - removed:
method TransportCase.setUp() - removed:
method TransportCase.tearDown() - removed:
method TransportCase.test_basic_get() - removed:
method TransportCase.test_cyclic_reference_channel() - removed:
method TransportCase.test_cyclic_reference_connection() - removed:
method TransportCase.test_cyclic_reference_transport() - removed:
method TransportCase.test_produce__consume() - removed:
method TransportCase.test_produce__consume_large_messages(bytes=…, n=…, charset=…) - removed:
method TransportCase.test_produce__consume_multiple() - removed:
method TransportCase.test_purge() - removed:
method TransportCase.test_timeout() - removed:
method TransportCase.verify_alive()
- added:
variable version_info_t
- added:
export ERR - added:
export Hub - added:
export READ - added:
export WRITE - added:
export get_event_loop - added:
export set_event_loop
- added:
function callback_for(h, fd, flag, *default) - added:
function repr_active(h) - added:
function repr_events(h, events) - added:
function repr_flag(flag) - added:
function repr_readers(h) - added:
function repr_writers(h)
- added:
class Hub(object) - added:
constructor Hub(timer=…) - added:
field Hub.ERR - added:
field Hub.READ - added:
field Hub.WRITE - added:
field Hub.on_close - added:
function get_event_loop() - added:
function set_event_loop(loop) - added:
method Hub.add(fd, callback, flags, args=…, consolidate=…) - added:
method Hub.add_reader(fds, callback, *args) - added:
method Hub.add_writer(fds, callback, *args) - added:
method Hub.call_at(when, callback, *args) - added:
method Hub.call_later(delay, callback, *args) - added:
method Hub.call_repeatedly(delay, callback, *args) - added:
method Hub.call_soon(callback, *args) - added:
method Hub.close(*args) - added:
method Hub.create_loop(generator=…, sleep=…, min=…, next=…, Empty=…, StopIteration=…, KeyError=…, READ=…, WRITE=…, ERR=…) - added:
method Hub.fire_timers(min_delay=…, max_delay=…, max_timers=…, propagate=…) - added:
method Hub.remove(fd) - added:
method Hub.remove_reader(fd) - added:
method Hub.remove_writer(fd) - added:
method Hub.repr_active() - added:
method Hub.repr_events(events) - added:
method Hub.reset() - added:
method Hub.run_forever() - added:
method Hub.run_once() - added:
method Hub.stop() - added:
property Hub.loop - added:
property Hub.scheduler
- added:
class DummyLock(object) - added:
class LaxBoundedSemaphore(object) - added:
constructor LaxBoundedSemaphore(value) - added:
method LaxBoundedSemaphore.acquire(callback, *partial_args) - added:
method LaxBoundedSemaphore.clear() - added:
method LaxBoundedSemaphore.grow(n=…) - added:
method LaxBoundedSemaphore.release() - added:
method LaxBoundedSemaphore.shrink(n=…)
- added:
class Entry(object) - added:
class Timer(object) - added:
constructor Entry(fun, args=…, kwargs=…) - added:
constructor Timer(max_interval=…, on_error=…, **kwargs) - added:
field Timer.Entry - added:
field Timer.on_error - added:
function to_timestamp(d, default_timezone=…) - added:
method Entry.cancel() - added:
method Timer.apply_entry(entry) - added:
method Timer.call_after(secs, fun, args=…, kwargs=…, priority=…) - added:
method Timer.call_at(eta, fun, args=…, kwargs=…, priority=…) - added:
method Timer.call_repeatedly(secs, fun, args=…, kwargs=…, priority=…) - added:
method Timer.cancel(tref) - added:
method Timer.clear() - added:
method Timer.enter_after(secs, entry, priority=…, time=…) - added:
method Timer.enter_at(entry, eta=…, priority=…, time=…) - added:
method Timer.handle_error(exc_info) - added:
method Timer.stop() - added:
property Timer.queue - added:
property Timer.schedule
- changed:
constructor LamportClock(initial_value=…) → constructor LamportClock(initial_value=…, Lock=…) - added:
class timetuple(tuple) - added:
field timetuple.clock - added:
field timetuple.id - added:
field timetuple.obj - added:
field timetuple.timestamp
- removed:
function ipublish(pool, fun, args=…, kwargs=…, errback=…, on_revive=…, **retry_policy) - removed:
function isend_reply(pool, exchange, req, msg, props, **retry_policy) - changed:
constructor Broadcast(name=…, queue=…, **kwargs) → constructor Broadcast(name=…, queue=…, auto_delete=…, exchange=…, alias=…, **kwargs) - changed:
function itermessages(conn, channel, queue, limit=…, timeout=…, Consumer=…, callbacks=…, **kwargs) → function itermessages(conn, channel, queue, limit=…, timeout=…, callbacks=…, **kwargs) - changed:
function send_reply(exchange, req, msg, producer=…, **props) → function send_reply(exchange, req, msg, producer=…, retry=…, retry_policy=…, **props) - added:
field Broadcast.attrs
- removed:
field Connection.create_backend - removed:
field Connection.more_to_read - removed:
method Connection.drain_nowait(*args, **kwargs) - removed:
property Connection.eventmap - changed:
method Connection.as_uri(include_password=…) → method Connection.as_uri(include_password=…, mask=…, getfields=…) - added:
field Connection.failover_strategies - added:
method Connection.get_heartbeat_interval() - added:
method Connection.register_with_event_loop(loop) - added:
property Connection.qos_semantics_matches_spec
- added:
class binding(Object) - added:
constructor binding(exchange=…, routing_key=…, arguments=…, unbind_arguments=…) - added:
field Queue.ContentDisallowed - added:
field binding.attrs - added:
method Exchange.binding(routing_key=…, arguments=…, unbind_arguments=…) - added:
method Queue.as_dict(recurse=…) - added:
method binding.bind(entity, nowait=…) - added:
method binding.declare(channel, nowait=…) - added:
method binding.unbind(entity, nowait=…)
- removed:
class StdChannelError(KombuError) - removed:
class StdConnectionError(KombuError) - added:
class DecodeError(SerializationError) - added:
class EncodeError(SerializationError) - added:
class SerializationError(KombuError) - added:
export ChannelError - added:
export ConnectionError - added:
export ResourceError
- added:
class WhateverIO(StringIO) - added:
class timespec(ctypes.Structure) - added:
function exec_(code, globs=…, locs=…) - added:
function items(d) - added:
function keys(d) - added:
function nextfun(it) - added:
function reraise(tp, value, tb=…) - added:
function values(d) - added:
function with_metaclass(Type, skip_attrs=…) - added:
method WhateverIO.write(data) - added:
variable BytesIO - added:
variable CLOCK_MONOTONIC - added:
variable CoreServices - added:
variable PY3 - added:
variable SYSTEM - added:
variable WhateverIO - added:
variable absolute_to_nanoseconds - added:
variable bytes_t - added:
variable clock_gettime - added:
variable ctypes - added:
variable exec_ - added:
variable libSystem - added:
variable librt - added:
variable long_t - added:
variable mach_absolute_time - added:
variable map - added:
variable module_name_t - added:
variable monotonic - added:
variable open_fqdn - added:
variable range - added:
variable reload - added:
variable string - added:
variable string_t - added:
variable text_t - added:
variable zip
- added:
class Message(object) - added:
constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, accept=…, **kwargs) - added:
field Message.MessageStateError - added:
field Message.errors - added:
method Message.ack() - added:
method Message.ack_log_error(logger, errors) - added:
method Message.decode() - added:
method Message.reject(requeue=…) - added:
method Message.reject_log_error(logger, errors, requeue=…) - added:
method Message.requeue() - added:
property Message.acknowledged - added:
property Message.payload - added:
variable ACK_STATES
- changed:
constructor Consumer(channel, queues=…, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…, on_message=…, accept=…) → constructor Consumer(channel, queues=…, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…, on_message=…, accept=…, tag_prefix=…) - changed:
method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…, retry=…, retry_policy=…, declare=…, **properties) → method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…, retry=…, retry_policy=…, declare=…, expiration=…, **properties) - added:
field Consumer.ContentDisallowed
- added:
method ConsumerMixin.consumer_context(**kwargs) - added:
method ConsumerMixin.create_connection()
- changed:
constructor Mailbox(namespace, type=…, connection=…, clock=…, accept=…) → constructor Mailbox(namespace, type=…, connection=…, clock=…, accept=…, serializer=…) - changed:
method Node.Consumer(channel=…, **options) → method Node.Consumer(channel=…, no_ack=…, accept=…, **options) - added:
field Mailbox.accept - added:
field Mailbox.serializer - added:
method Node.on_decode_error(message, exc)
- removed:
variable decode - removed:
variable encode - added:
variable dumps - added:
variable loads
- added:
export string_t
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
field Channel.default_visibility_timeout - added:
field Channel.domain_format - added:
field Transport.Channel - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.polling_interval - added:
method Channel.basic_ack(delivery_tag) - added:
method Channel.basic_cancel(consumer_tag) - added:
method Channel.basic_consume(queue, no_ack, *args, **kwargs) - added:
method Channel.delete_message(queue, message_id) - added:
method Channel.entity_name(name, table=…) - added:
property Channel.conninfo - added:
property Channel.queue_name_prefix - added:
property Channel.slmq - added:
property Channel.transport_options - added:
property Channel.visibility_timeout - added:
variable CHARS_REPLACE_TABLE - added:
variable ResponseError - added:
variable get_client
- added:
method Channel.drain_events(timeout=…) - added:
method Channel.queue_bind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - added:
variable SQS_MAX_MESSAGES - added:
variable logger
- removed:
field Transport.nb_keep_draining - removed:
method Transport.eventmap(connection) - removed:
method Transport.on_poll_init(poller) - removed:
method Transport.on_poll_start() - added:
class NA(object) - added:
class NAx(object) - added:
field Connection.connected - added:
method Transport.register_with_event_loop(connection, loop) - added:
variable AMQPChannelException - added:
variable AMQPConnectionException - added:
variable amqp - added:
variable transport
- removed:
class Message(object) - removed:
constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, accept=…, **kwargs) - removed:
field Message.MessageStateError - removed:
field Transport.nb_keep_draining - removed:
method Message.ack() - removed:
method Message.ack_log_error(logger, errors) - removed:
method Message.decode() - removed:
method Message.reject() - removed:
method Message.reject_log_error(logger, errors) - removed:
method Message.requeue() - removed:
method Transport.eventmap(connection) - removed:
method Transport.on_poll_empty() - removed:
method Transport.on_poll_init(poller) - removed:
method Transport.on_poll_start() - removed:
property Message.acknowledged - removed:
property Message.payload - removed:
variable ACKNOWLEDGED_STATES - added:
export Message - added:
field Transport.can_parse_url - added:
method Transport.get_heartbeat_interval(connection) - added:
method Transport.on_readable(connection, loop) - added:
method Transport.qos_semantics_matches_spec(connection) - added:
method Transport.register_with_event_loop(loop) - added:
method Transport.unregister_from_event_loop(loop)
- added:
constructor Transport(*args, **kwargs) - added:
variable beanstalkc
- added:
constructor Transport(*args, **kwargs) - added:
variable couchdb
- removed:
export Queue - removed:
export StdChannelError - removed:
export StdConnectionError - removed:
field Transport.connection_errors - added:
class KombuAppConfig(AppConfig) - added:
export Empty - added:
export bytes_to_str - added:
export cached_property - added:
export symbol_by_name - added:
field Channel.queue_model - added:
field KombuAppConfig.label - added:
field KombuAppConfig.name - added:
field KombuAppConfig.verbose_name - added:
property Channel.Queue - added:
variable default_app_config
- added:
function commit_on_success(fun) - added:
variable commit_on_success
- added:
variable SOUTH_ERROR_MESSAGE
- added:
field Message.Meta.app_label - added:
field Queue.Meta.app_label
- removed:
field Transport.channel_errors - removed:
field Transport.connection_errors
- removed:
field Transport.nb_keep_draining - removed:
method Transport.eventmap(connection) - removed:
method Transport.on_poll_init(poller) - removed:
method Transport.on_poll_start() - added:
field Transport.default_ssl_port - added:
method Transport.qos_semantics_matches_spec(connection) - added:
method Transport.register_with_event_loop(connection, loop) - added:
variable DEFAULT_SSL_PORT - added:
variable W_VERSION
- added:
field Channel.supports_fanout - added:
method Channel.close()
- removed:
method Channel.close() - added:
class BroadcastCursor(object) - added:
class CursorType(object) - added:
constructor BroadcastCursor(cursor) - added:
field BroadcastCursor.next - added:
field Transport.can_parse_url - added:
method BroadcastCursor.close() - added:
method BroadcastCursor.get_size() - added:
method BroadcastCursor.purge(rewind=…) - added:
method Channel.create_broadcast_cursor(exchange, routing_key, pattern, queue) - added:
method Channel.get_broadcast() - added:
method Channel.get_broadcast_cursor(queue) - added:
method Channel.get_messages() - added:
method Channel.get_routing() - added:
variable DEFAULT_BROADCAST_COLLECTION - added:
variable DEFAULT_MESSAGES_COLLECTION - added:
variable DEFAULT_ROUTING_COLLECTION
- removed:
field Transport.nb_keep_draining - removed:
method Transport.eventmap(connection) - removed:
method Transport.on_poll_init(poller) - removed:
method Transport.on_poll_start() - changed:
constructor Transport(client, **kwargs) → constructor Transport(client, default_port=…, default_ssl_port=…, **kwargs) - changed:
method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) → method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…, _Message=…) - added:
field Transport.default_ssl_port - added:
field Transport.recoverable_channel_errors - added:
field Transport.recoverable_connection_errors - added:
method Transport.get_heartbeat_interval(connection) - added:
method Transport.qos_semantics_matches_spec(connection) - added:
method Transport.register_with_event_loop(connection, loop) - added:
method Transport.verify_connection(connection) - added:
variable DEFAULT_SSL_PORT
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.state - added:
method Channel.after_reply_message_received(queue) - added:
method Channel.queues() - added:
method Transport.driver_version() - added:
property Channel.shared_queues - added:
property Transport.shared_queues - added:
variable DEFAULT_PORT - added:
variable E_LOOKUP - added:
variable NamingError - added:
variable pyro
- added:
class AuthenticationFailure(Exception) - added:
class Channel(base.StdChannel) - added:
class Connection(object) - added:
class QoS(object) - added:
class Transport(base.Transport) - added:
constructor Channel(connection, transport) - added:
constructor Connection(**connection_options) - added:
constructor QoS(session, prefetch_count=…) - added:
constructor Transport(*args, **kwargs) - added:
field Channel.Message - added:
field Channel.QoS - added:
field Channel.body_encoding - added:
field Channel.codecs - added:
field Connection.Channel - added:
field Transport.Connection - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
field Transport.recoverable_channel_errors - added:
field Transport.recoverable_connection_errors - added:
field Transport.supports_ev - added:
function dependency_is_none(dependency) - added:
method Channel.basic_ack(delivery_tag) - added:
method Channel.basic_cancel(consumer_tag) - added:
method Channel.basic_consume(queue, no_ack, callback, consumer_tag, **kwargs) - added:
method Channel.basic_get(queue, no_ack=…, **kwargs) - added:
method Channel.basic_publish(message, exchange, routing_key, **kwargs) - added:
method Channel.basic_qos(prefetch_count, *args) - added:
method Channel.basic_reject(delivery_tag, requeue=…) - added:
method Channel.close() - added:
method Channel.decode_body(body, encoding=…) - added:
method Channel.encode_body(body, encoding=…) - added:
method Channel.exchange_declare(exchange=…, type=…, durable=…, **kwargs) - added:
method Channel.exchange_delete(exchange_name, **kwargs) - added:
method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method Channel.queue_bind(queue, exchange, routing_key, **kwargs) - added:
method Channel.queue_declare(queue, passive=…, durable=…, exclusive=…, auto_delete=…, nowait=…, arguments=…) - added:
method Channel.queue_delete(queue, if_unused=…, if_empty=…, **kwargs) - added:
method Channel.queue_purge(queue, **kwargs) - added:
method Channel.queue_unbind(queue, exchange, routing_key, **kwargs) - added:
method Channel.typeof(exchange, default=…) - added:
method Connection.close() - added:
method Connection.close_channel(channel) - added:
method Connection.get_qpid_connection() - added:
method QoS.ack(delivery_tag) - added:
method QoS.append(message, delivery_tag) - added:
method QoS.can_consume() - added:
method QoS.can_consume_max_estimate() - added:
method QoS.get(delivery_tag) - added:
method QoS.reject(delivery_tag, requeue=…) - added:
method Transport.close_connection(connection) - added:
method Transport.create_channel(connection) - added:
method Transport.drain_events(connection, timeout=…, **kwargs) - added:
method Transport.establish_connection() - added:
method Transport.on_readable(connection, loop) - added:
method Transport.register_with_event_loop(connection, loop) - added:
method Transport.verify_runtime_environment() - added:
property Channel.qos - added:
property Transport.default_connection_params - added:
variable ConnectionError - added:
variable NotFound - added:
variable OBJECT_ALREADY_EXISTS_STRING - added:
variable PY3 - added:
variable QpidEmpty - added:
variable SessionClosed - added:
variable VERSION - added:
variable fcntl - added:
variable logger - added:
variable qpid - added:
variable qpidtoollibs
- removed:
class Channel(virtual.Channel) - removed:
class MultiChannelPoller(object) - removed:
class MutexHeld(Exception) - removed:
class QoS(virtual.QoS) - removed:
class Transport(virtual.Transport) - removed:
constructor Channel(*args, **kwargs) - removed:
constructor MultiChannelPoller() - removed:
constructor QoS(*args, **kwargs) - removed:
constructor Transport(*args, **kwargs) - removed:
field Channel.QoS - removed:
field Channel.ack_emulation - removed:
field Channel.from_transport_options - removed:
field Channel.keyprefix_queue - removed:
field Channel.max_connections - removed:
field Channel.priority_steps - removed:
field Channel.sep - removed:
field Channel.socket_timeout - removed:
field Channel.supports_fanout - removed:
field Channel.unacked_index_key - removed:
field Channel.unacked_key - removed:
field Channel.unacked_mutex_expire - removed:
field Channel.unacked_mutex_key - removed:
field Channel.unacked_restore_limit - removed:
field Channel.visibility_timeout - removed:
field MultiChannelPoller.eventflags - removed:
field QoS.restore_at_shutdown - removed:
field Transport.Channel - removed:
field Transport.default_port - removed:
field Transport.driver_name - removed:
field Transport.driver_type - removed:
field Transport.polling_interval - removed:
field Transport.supports_ev - removed:
function Mutex(client, name, expire) - removed:
function register_after_fork(*args, **kwargs) - removed:
method Channel.basic_cancel(consumer_tag) - removed:
method Channel.basic_consume(queue, *args, **kwargs) - removed:
method Channel.close() - removed:
method Channel.conn_or_acquire(client=…) - removed:
method Channel.get_table(exchange) - removed:
method Channel.priority(n) - removed:
method MultiChannelPoller.add(channel) - removed:
method MultiChannelPoller.close() - removed:
method MultiChannelPoller.discard(channel) - removed:
method MultiChannelPoller.get(timeout=…) - removed:
method MultiChannelPoller.handle_event(fileno, event) - removed:
method MultiChannelPoller.on_poll_empty() - removed:
method MultiChannelPoller.on_poll_init(poller) - removed:
method MultiChannelPoller.on_poll_start() - removed:
method QoS.ack(delivery_tag) - removed:
method QoS.append(message, delivery_tag) - removed:
method QoS.pipe_or_acquire(pipe=…) - removed:
method QoS.reject(delivery_tag, requeue=…) - removed:
method QoS.restore_by_tag(tag, client=…) - removed:
method QoS.restore_unacked() - removed:
method QoS.restore_visible(start=…, num=…, interval=…) - removed:
method Transport.driver_version() - removed:
method Transport.handle_event(fileno, event) - removed:
method Transport.on_poll_empty() - removed:
method Transport.on_poll_init(poller) - removed:
method Transport.on_poll_start() - removed:
property Channel.active_queues - removed:
property Channel.client - removed:
property Channel.pool - removed:
property Channel.subclient - removed:
property MultiChannelPoller.fds - removed:
property QoS.unacked_index_key - removed:
property QoS.unacked_key - removed:
property QoS.unacked_mutex_expire - removed:
property QoS.unacked_mutex_key - removed:
property QoS.visibility_timeout - removed:
variable DEFAULT_DB - removed:
variable DEFAULT_PORT - removed:
variable NO_ROUTE_ERROR - removed:
variable PRIORITY_STEPS - removed:
variable logger - removed:
variable redis
- removed:
export Message - removed:
export Queue - removed:
export StdChannelError - removed:
export StdConnectionError - removed:
field Transport.channel_errors - added:
constructor Channel(connection, **kwargs) - added:
export Empty - added:
export MessageBase - added:
export ModelBase - added:
export QueueBase - added:
export bytes_to_str - added:
export cached_property - added:
export class_registry - added:
field Transport.can_parse_url - added:
property Channel.message_cls - added:
property Channel.queue_cls
- removed:
field Message.queue_id - removed:
field Queue.messages - changed:
class Message(ModelBase) → class Message(object) - changed:
class Queue(ModelBase) → class Queue(object) - added:
method Message.queue_id() - added:
method Queue.messages() - added:
variable class_registry
- removed:
export Finalize - removed:
export StdChannelError - changed:
method Channel.queue_delete(queue, if_unusued=…, if_empty=…, **kwargs) → method Channel.queue_delete(queue, if_unused=…, if_empty=…, **kwargs) - changed:
method QoS.restore_visible(start=…, num=…, interval=…) → method QoS.restore_visible(*args, **kwargs) - added:
export ChannelError - added:
export Empty - added:
export ResourceError - added:
export items - added:
export kwdict - added:
export monotonic - added:
field Transport.channel_max - added:
method QoS.can_consume_max_estimate() - added:
variable ARRAY_TYPE_H - added:
variable NOT_EQUIVALENT_FMT
- removed:
field Transport.channel_errors - removed:
field Transport.nb_keep_draining - removed:
method MultiChannelPoller.handle_event(fileno, event) - removed:
method Transport.handle_event(fileno, event) - removed:
method Transport.on_poll_init(poller) - removed:
method Transport.on_poll_start() - added:
field Transport.can_parse_url - added:
method MultiChannelPoller.on_readable(fileno) - added:
method Transport.on_readable(fileno) - added:
method Transport.register_with_event_loop(connection, loop) - added:
variable dumps - added:
variable loads
- added:
variable MAX_PRIORITY
- added:
class EqualityDict(dict) - added:
class cached_property(object) - added:
constructor cached_property(fget=…, fset=…, fdel=…, doc=…) - added:
function emergency_dump_state(state, open_file=…, dump=…) - added:
function fileno(f) - added:
function fxrange(start=…, stop=…, step=…, repeatlast=…) - added:
function fxrangemax(start=…, stop=…, step=…, max=…) - added:
function kwdict(kwargs) - added:
function maybe_fileno(f) - added:
function maybe_list(v) - added:
function nested(*managers) - added:
function reprcall(name, args=…, kwargs=…, sep=…) - added:
function reprkwargs(kwargs, sep=…, fmt=…) - added:
function retry_over_time(fun, catch, args=…, kwargs=…, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…, callback=…) - added:
function say(m, *fargs, **fkwargs) - added:
function uuid() - added:
method cached_property.deleter(fdel) - added:
method cached_property.setter(fset)
- removed:
class LifoQueue(Queue) - removed:
class WatchedFileHandler(logging.FileHandler) - removed:
class WhateverIO(StringIO) - removed:
constructor WatchedFileHandler(*args, **kwargs) - removed:
function next(it, *args) - removed:
method WatchedFileHandler.emit(record) - removed:
method WhateverIO.write(data) - removed:
variable BytesIO - removed:
variable WatchedFileHandler - removed:
variable WhateverIO - removed:
variable is_py3k - removed:
variable next - added:
function timedelta_seconds(delta) - added:
variable HAVE_TIMEDELTA_TOTAL_SECONDS
- changed:
function default_encode(obj) → function default_encode(obj, file=…) - changed:
function default_encoding() → function default_encoding(file=…) - added:
function get_default_encoding_file() - added:
function set_default_encoding_file(file) - added:
variable default_encoding_file
- removed:
class Finalize(object) - removed:
constructor Finalize(obj, callback, args=…, kwargs=…, exitpriority=…) - removed:
method Finalize.cancel() - removed:
method Finalize.still_active()
- removed:
class promise(object) - removed:
constructor promise(fun, *args, **kwargs) - removed:
function maybe_promise(value) - removed:
method promise.evaluate() - added:
class lazy(object) - added:
constructor lazy(fun, *args, **kwargs) - added:
function is_list(l, scalars=…, iters=…) - added:
function maybe_evaluate(value) - added:
function maybe_list(l, scalars=…) - added:
method lazy.evaluate()
- added:
function version_string_as_tuple(s)
- added:
function as_url(scheme, host=…, port=…, user=…, password=…, path=…, query=…, sanitize=…, mask=…) - added:
function maybe_sanitize_url(url, mask=…) - added:
function sanitize_url(url, mask=…) - added:
variable safequote
- removed:
function send_as_task(connection, fun, args=…, kwargs=…, priority=…) - removed:
variable connection - removed:
variable priority_to_routing_key
- removed:
variable task_exchange - removed:
variable task_queues
- removed:
function hello_task(who=…)
- removed:
class Worker(ConsumerMixin) - removed:
constructor Worker(connection) - removed:
method Worker.get_consumers(Consumer, channel) - removed:
method Worker.process_task(body, message) - removed:
variable logger