Source: celery
Version: 5.2.6-2
Severity: serious
Justification: FTBFS
Tags: bookworm sid ftbfs
User: lu...@debian.org
Usertags: ftbfs-20220917 ftbfs-bookworm
Hi,
During a rebuild of all packages in sid, your package failed to build
on amd64.
Relevant part (hopefully):
> debian/rules binary
> dh binary --with python3,sphinxdoc --buildsystem=pybuild
> dh_update_autotools_config -O--buildsystem=pybuild
> dh_autoreconf -O--buildsystem=pybuild
> dh_auto_configure -O--buildsystem=pybuild
> I: pybuild base:240: python3.10 setup.py config
> /usr/lib/python3/dist-packages/setuptools/config/setupcfg.py:508:
> SetuptoolsDeprecationWarning: The license_file parameter is deprecated, use
> license_files instead.
> warnings.warn(msg, warning_class)
> running config
> dh_auto_build -O--buildsystem=pybuild
> I: pybuild base:240: /usr/bin/python3 setup.py build
> /usr/lib/python3/dist-packages/setuptools/config/setupcfg.py:508:
> SetuptoolsDeprecationWarning: The license_file parameter is deprecated, use
> license_files instead.
> warnings.warn(msg, warning_class)
> running build
> running build_py
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/canvas.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/platforms.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/__main__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/states.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/exceptions.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/_state.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/bootsteps.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/schedules.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/signals.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/beat.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/result.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> copying celery/local.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/components.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/worker.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/pidbox.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/autoscale.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/control.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/heartbeat.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/state.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/strategy.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/loops.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> copying celery/worker/request.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/loaders
> copying celery/loaders/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/loaders
> copying celery/loaders/default.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/loaders
> copying celery/loaders/app.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/loaders
> copying celery/loaders/base.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/loaders
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/graph.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/imports.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/threads.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/log.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/deprecated.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/objects.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/timer2.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/debug.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/collections.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/term.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/abstract.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/text.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/time.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/iso8601.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/nodenames.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/serialization.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/sysinfo.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/saferepr.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> copying celery/utils/functional.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/filesystem.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/azureblockblob.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/dynamodb.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/cassandra.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/base.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/cache.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/consul.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/elasticsearch.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/couchbase.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/s3.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/rpc.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/mongodb.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/couchdb.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/asynchronous.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/cosmosdbsql.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/arangodb.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> copying celery/backends/redis.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends
> creating
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/asynpool.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/prefork.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/base.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/gevent.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/eventlet.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/solo.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> copying celery/concurrency/thread.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/concurrency
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> copying celery/contrib/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> copying celery/contrib/abortable.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> copying celery/contrib/sphinx.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> copying celery/contrib/migrate.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> copying celery/contrib/pytest.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> copying celery/contrib/rdb.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/fixups
> copying celery/fixups/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/fixups
> copying celery/fixups/django.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/fixups
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/security
> copying celery/security/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/security
> copying celery/security/key.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/security
> copying celery/security/certificate.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/security
> copying celery/security/serialization.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/security
> copying celery/security/utils.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/security
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/graph.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/purge.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/worker.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/upgrade.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/events.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/shell.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/amqp.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/logtool.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/call.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/base.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/control.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/list.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/migrate.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/beat.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/result.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/multi.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> copying celery/bin/celery.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/dumper.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/snapshot.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/dispatcher.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/event.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/state.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/cursesmon.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> copying celery/events/receiver.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/events
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/registry.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/events.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/log.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/defaults.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/amqp.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/autoretry.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/trace.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/routes.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/annotations.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/base.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/control.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/task.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/backends.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/builtins.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> copying celery/app/utils.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app
> creating /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/apps
> copying celery/apps/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/apps
> copying celery/apps/worker.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/apps
> copying celery/apps/beat.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/apps
> copying celery/apps/multi.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/apps
> creating
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/events.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/mingle.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/consumer.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/control.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/agent.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/tasks.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/gossip.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/connection.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> copying celery/worker/consumer/heart.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer
> creating
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/static
> copying celery/utils/static/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/static
> creating
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/dispatch
> copying celery/utils/dispatch/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/dispatch
> copying celery/utils/dispatch/signal.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/dispatch
> creating
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends/database
> copying celery/backends/database/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends/database
> copying celery/backends/database/models.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends/database
> copying celery/backends/database/session.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/backends/database
> creating
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> copying celery/contrib/testing/__init__.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> copying celery/contrib/testing/worker.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> copying celery/contrib/testing/mocks.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> copying celery/contrib/testing/manager.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> copying celery/contrib/testing/app.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> copying celery/contrib/testing/tasks.py ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/contrib/testing
> running egg_info
> writing celery.egg-info/PKG-INFO
> writing dependency_links to celery.egg-info/dependency_links.txt
> writing entry points to celery.egg-info/entry_points.txt
> writing requirements to celery.egg-info/requires.txt
> writing top-level names to celery.egg-info/top_level.txt
> writing manifest file 'celery.egg-info/SOURCES.txt'
> reading manifest file 'celery.egg-info/SOURCES.txt'
> reading manifest template 'MANIFEST.in'
> warning: no files found matching '*' under directory 'extra/centos'
> warning: no previously-included files matching '*' found under directory
> 'docs/_build'
> warning: no previously-included files matching '__pycache__' found under
> directory '*'
> warning: no previously-included files matching '*.py[co]' found under
> directory '*'
> warning: no previously-included files matching '.*.sw[a-z]' found under
> directory '*'
> adding license file 'LICENSE'
> writing manifest file 'celery.egg-info/SOURCES.txt'
> copying celery/utils/static/celery_128.png ->
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/static
> dh_auto_test -O--buildsystem=pybuild
> I: pybuild base:240: cd /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build;
> python3.10 -m pytest --ignore=t/unit/backends/test_base.py
> --ignore=t/unit/backends/test_rpc.py --ignore=t/unit/contrib/test_pytest.py
> --ignore=t/unit/concurrency/test_eventlet.py
> --ignore=t/unit/concurrency/test_prefork.py -k "not
> test_check_privileges[accept_content0] and not
> test_check_privileges[accept_content1] and not
> test_check_privileges[accept_content2] and not
> test_regression_worker_startup_info and not test_with_guid and not
> test_only_gid and not test_init_mongodb_dnspython2_pymongo3_seedlist" t/unit
> ============================= test session starts
> ==============================
> platform linux -- Python 3.10.7, pytest-7.1.2, pluggy-1.0.0+repack
> rootdir: /<<PKGBUILDDIR>>, configfile: pyproject.toml
> plugins: flaky-3.7.0, subtests-0.8.0, timeout-2.1.0, case-1.5.3
> collected 2374 items / 8 deselected / 9 skipped / 2366 selected
>
> t/unit/test_canvas.py . [
> 0%]
> t/unit/app/test_amqp.py ................................................ [
> 2%]
> ... [
> 2%]
> t/unit/app/test_annotations.py ..... [
> 2%]
> t/unit/app/test_app.py ................................................. [
> 4%]
> ................................................... [
> 6%]
> t/unit/app/test_backends.py ...... [
> 6%]
> t/unit/app/test_beat.py ................................................ [
> 8%]
> ............... [
> 9%]
> t/unit/app/test_builtins.py ............... [
> 10%]
> t/unit/app/test_celery.py ..... [
> 10%]
> t/unit/app/test_control.py ............................................. [
> 12%]
> ..................... [
> 13%]
> t/unit/app/test_defaults.py .... [
> 13%]
> t/unit/app/test_exceptions.py ..... [
> 13%]
> t/unit/app/test_loaders.py ....................... [
> 14%]
> t/unit/app/test_log.py ....................................... [
> 16%]
> t/unit/app/test_registry.py ..... [
> 16%]
> t/unit/app/test_routes.py ............... [
> 17%]
> t/unit/app/test_schedules.py sssssssss.................................. [
> 18%]
> ........................................................................ [
> 21%]
> s.... [
> 22%]
> t/unit/app/test_utils.py ........ [
> 22%]
> t/unit/apps/test_multi.py .......................... [
> 23%]
> t/unit/backends/test_cache.py ........................ [
> 24%]
> t/unit/backends/test_cassandra.py ........... [
> 25%]
> t/unit/backends/test_database.py ................................... [
> 26%]
> t/unit/backends/test_dynamodb.py ................................ [
> 27%]
> t/unit/backends/test_filesystem.py .............. [
> 28%]
> t/unit/backends/test_mongodb.py ....sss................................. [
> 30%]
> ................................................... [
> 32%]
> t/unit/backends/test_redis.py .......................................... [
> 34%]
> ........................................ [
> 35%]
> t/unit/concurrency/test_concurrency.py .......................... [
> 36%]
> t/unit/concurrency/test_gevent.py .... [
> 37%]
> t/unit/concurrency/test_pool.py . [
> 37%]
> t/unit/concurrency/test_solo.py .... [
> 37%]
> t/unit/concurrency/test_thread.py ... [
> 37%]
> t/unit/contrib/test_abortable.py .... [
> 37%]
> t/unit/contrib/test_migrate.py .................. [
> 38%]
> t/unit/contrib/test_rdb.py .... [
> 38%]
> t/unit/contrib/test_sphinx.py s [
> 38%]
> t/unit/events/test_cursesmon.py .... [
> 38%]
> t/unit/events/test_events.py .......................... [
> 39%]
> t/unit/events/test_snapshot.py ....... [
> 40%]
> t/unit/events/test_state.py ....................s....................... [
> 41%]
> [
> 41%]
> t/unit/fixups/test_django.py ...................... [
> 42%]
> t/unit/security/test_certificate.py ..s..... [
> 43%]
> t/unit/security/test_key.py ... [
> 43%]
> t/unit/security/test_security.py ....s... [
> 43%]
> t/unit/security/test_serialization.py ........ [
> 43%]
> t/unit/tasks/test_canvas.py ............................................ [
> 45%]
> ............................................x..x........................ [
> 48%]
> ................,,.....,,,.,,,.,,,.,,,.... [
> 50%]
> t/unit/tasks/test_chord.py .................. [
> 50%]
> t/unit/tasks/test_context.py ..... [
> 51%]
> t/unit/tasks/test_result.py ..................s......................... [
> 52%]
> ............................................F........... [
> 55%]
> t/unit/tasks/test_states.py ............. [
> 55%]
> t/unit/tasks/test_tasks.py F.F.....FFFFFFFF.FFFFFFFFFFFFFFFFFFFF........ [
> 57%]
> ................................F........ [
> 59%]
> t/unit/tasks/test_trace.py ........................................... [
> 61%]
> t/unit/utils/test_collections.py .................F..................... [
> 62%]
> ............ [
> 63%]
> t/unit/utils/test_debug.py ............. [
> 63%]
> t/unit/utils/test_deprecated.py ... [
> 64%]
> t/unit/utils/test_dispatcher.py .......... [
> 64%]
> t/unit/utils/test_functional.py ...................x...,,,,,,........... [
> 65%]
> ................... [
> 66%]
> t/unit/utils/test_graph.py ......... [
> 67%]
> t/unit/utils/test_imports.py ........ [
> 67%]
> t/unit/utils/test_local.py ....................... [
> 68%]
> t/unit/utils/test_nodenames.py . [
> 68%]
> t/unit/utils/test_objects.py . [
> 68%]
> t/unit/utils/test_pickle.py .. [
> 68%]
> t/unit/utils/test_platforms.py ......................................... [
> 70%]
> ....................................................... [
> 72%]
> t/unit/utils/test_saferepr.py .......................................... [
> 74%]
> ............................ [
> 75%]
> t/unit/utils/test_serialization.py .............................. [
> 76%]
> t/unit/utils/test_sysinfo.py .. [
> 77%]
> t/unit/utils/test_term.py ........................ [
> 78%]
> t/unit/utils/test_text.py ............. [
> 78%]
> t/unit/utils/test_threads.py ...... [
> 78%]
> t/unit/utils/test_time.py .............................................. [
> 80%]
> ....... [
> 81%]
> t/unit/utils/test_timer2.py ......... [
> 81%]
> t/unit/utils/test_utils.py .... [
> 81%]
> t/unit/worker/test_autoscale.py ............. [
> 82%]
> t/unit/worker/test_bootsteps.py .............................. [
> 83%]
> t/unit/worker/test_components.py ......... [
> 83%]
> t/unit/worker/test_consumer.py ......................................... [
> 85%]
> .... [
> 85%]
> t/unit/worker/test_control.py .......................................... [
> 87%]
> . [
> 87%]
> t/unit/worker/test_heartbeat.py ..... [
> 87%]
> t/unit/worker/test_loops.py ........................................ [
> 89%]
> t/unit/worker/test_request.py ......F............FFFFFFF......F......... [
> 91%]
> ...........F....F.....FF.......................F.....F........... [
> 93%]
> t/unit/worker/test_revoke.py . [
> 93%]
> t/unit/worker/test_state.py .............. [
> 94%]
> t/unit/worker/test_strategy.py ......................................... [
> 96%]
> .................... [
> 97%]
> t/unit/worker/test_worker.py ..................................s........ [
> 98%]
> ........................
> [100%]
>
> =================================== FAILURES
> ===================================
> ______________________ test_EagerResult.test_wait_raises
> _______________________
>
> self = <t.unit.tasks.test_result.test_EagerResult object at 0x7f682bbeb640>
>
> def test_wait_raises(self):
> res = self.raising.apply(args=[3, 3])
> with pytest.raises(KeyError):
> > res.wait()
>
> t/unit/tasks/test_result.py:946:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <EagerResult: 804981d6-437e-4a46-b83c-65cc7d6a265b>, timeout = None
> propagate = True, disable_sync_subtasks = True, kwargs = {}
>
> def get(self, timeout=None, propagate=True,
> disable_sync_subtasks=True, **kwargs):
> if disable_sync_subtasks:
> assert_will_not_block()
>
> if self.successful():
> return self.result
> elif self.state in states.PROPAGATE_STATES:
> if propagate:
> > raise self.result if isinstance(
> self.result, Exception) else Exception(self.result)
> E billiard.einfo.ExceptionWithTraceback:
> E """
> E Traceback (most recent call last):
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> E R = retval = fun(*args, **kwargs)
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_result.py",
> line 940, in raising
> E raise KeyError(x, y)
> E KeyError: (3, 3)
> E """
>
> celery/result.py:1005: ExceptionWithTraceback
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.app.trace:trace.py:265 Task
> t.unit.tasks.test_result.raising[804981d6-437e-4a46-b83c-65cc7d6a265b] raised
> unexpected: ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_result.py",
> line 940, in raising
> raise KeyError(x, y)
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_result.py",
> line 940, in raising
> raise KeyError(x, y)
> KeyError: (3, 3)
> """
> _________________________ test_task_retries.test_retry
> _________________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b750a30>
>
> def test_retry(self):
> self.retry_task.max_retries = 3
> self.retry_task.iterations = 0
> self.retry_task.apply([0xFF, 0xFFFF])
> > assert self.retry_task.iterations == 4
> E assert 1 == 4
> E + where 1 = <@task: t.unit.tasks.test_tasks.retry_task of
> celery.tests at 0x7f68237c6ce0>.iterations
> E + where <@task: t.unit.tasks.test_tasks.retry_task of
> celery.tests at 0x7f68237c6ce0> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682b750a30>.retry_task
>
> t/unit/tasks/test_tasks.py:380: AssertionError
> _____________________ test_task_retries.test_retry_no_args
> _____________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b7507c0>
>
> def test_retry_no_args(self):
> self.retry_task_noargs.max_retries = 3
> self.retry_task_noargs.iterations = 0
> self.retry_task_noargs.apply(propagate=True).get()
> > assert self.retry_task_noargs.iterations == 4
> E assert 1 == 4
> E + where 1 = <@task: t.unit.tasks.test_tasks.retry_task_noargs of
> celery.tests at 0x7f6823cc8af0>.iterations
> E + where <@task: t.unit.tasks.test_tasks.retry_task_noargs of
> celery.tests at 0x7f6823cc8af0> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682b7507c0>.retry_task_noargs
>
> t/unit/tasks/test_tasks.py:407: AssertionError
> _______________ test_task_retries.test_raise_without_throw_eager
> _______________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b752860>
>
> def test_raise_without_throw_eager(self):
> > assert self.retry_task_raise_without_throw.apply().get() == 42
> E assert None == 42
> E + where None = <bound method EagerResult.get of <EagerResult:
> 4e725a17-d92f-45e6-b119-1f02dc244983>>()
> E + where <bound method EagerResult.get of <EagerResult:
> 4e725a17-d92f-45e6-b119-1f02dc244983>> = <EagerResult:
> 4e725a17-d92f-45e6-b119-1f02dc244983>.get
> E + where <EagerResult: 4e725a17-d92f-45e6-b119-1f02dc244983> =
> <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task_raise_without_throw of celery.tests at
> 0x7f68237a97e0>>()
> E + where <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task_raise_without_throw of celery.tests at
> 0x7f68237a97e0>> = <@task:
> t.unit.tasks.test_tasks.retry_task_raise_without_throw of celery.tests at
> 0x7f68237a97e0>.apply
> E + where <@task:
> t.unit.tasks.test_tasks.retry_task_raise_without_throw of celery.tests at
> 0x7f68237a97e0> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682b752860>.retry_task_raise_without_throw
>
> t/unit/tasks/test_tasks.py:448: AssertionError
> ________________ test_task_retries.test_return_with_throw_eager
> ________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b751c90>
>
> def test_return_with_throw_eager(self):
> > assert self.retry_task_return_with_throw.apply().get() == 42
> E assert None == 42
> E + where None = <bound method EagerResult.get of <EagerResult:
> efec8be9-9650-4ba3-ac43-97d6901c1f78>>()
> E + where <bound method EagerResult.get of <EagerResult:
> efec8be9-9650-4ba3-ac43-97d6901c1f78>> = <EagerResult:
> efec8be9-9650-4ba3-ac43-97d6901c1f78>.get
> E + where <EagerResult: efec8be9-9650-4ba3-ac43-97d6901c1f78> =
> <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task_return_with_throw of celery.tests at
> 0x7f682378d120>>()
> E + where <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task_return_with_throw of celery.tests at
> 0x7f682378d120>> = <@task:
> t.unit.tasks.test_tasks.retry_task_return_with_throw of celery.tests at
> 0x7f682378d120>.apply
> E + where <@task:
> t.unit.tasks.test_tasks.retry_task_return_with_throw of celery.tests at
> 0x7f682378d120> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682b751c90>.retry_task_return_with_throw
>
> t/unit/tasks/test_tasks.py:451: AssertionError
> __________ test_task_retries.test_eager_retry_with_single_new_params
> ___________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b750be0>
>
> def test_eager_retry_with_single_new_params(self):
> > assert self.retry_task_auto_retry_with_single_new_arg.apply().get()
> > == "test"
> E AssertionError: assert None == 'test'
> E + where None = <bound method EagerResult.get of <EagerResult:
> b6610fcc-8349-4da8-a351-e3ceac0d113b>>()
> E + where <bound method EagerResult.get of <EagerResult:
> b6610fcc-8349-4da8-a351-e3ceac0d113b>> = <EagerResult:
> b6610fcc-8349-4da8-a351-e3ceac0d113b>.get
> E + where <EagerResult: b6610fcc-8349-4da8-a351-e3ceac0d113b> =
> <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_single_new_arg of
> celery.tests at 0x7f68237a9f60>>()
> E + where <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_single_new_arg of
> celery.tests at 0x7f68237a9f60>> = <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_single_new_arg of
> celery.tests at 0x7f68237a9f60>.apply
> E + where <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_single_new_arg of
> celery.tests at 0x7f68237a9f60> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682b750be0>.retry_task_auto_retry_with_single_new_arg
>
> t/unit/tasks/test_tasks.py:454: AssertionError
> ______________ test_task_retries.test_eager_retry_with_new_params
> ______________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b751b40>
>
> def test_eager_retry_with_new_params(self):
> > assert
> > self.retry_task_auto_retry_with_new_args.si(place_holder="test").apply().get()
> > == "test"
> E AssertionError: assert None == 'test'
> E + where None = <bound method EagerResult.get of <EagerResult:
> 3d8b33b2-4dbd-4ead-aad3-2b47c641d460>>()
> E + where <bound method EagerResult.get of <EagerResult:
> 3d8b33b2-4dbd-4ead-aad3-2b47c641d460>> = <EagerResult:
> 3d8b33b2-4dbd-4ead-aad3-2b47c641d460>.get
> E + where <EagerResult: 3d8b33b2-4dbd-4ead-aad3-2b47c641d460> =
> <bound method Signature.apply of
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args(place_holder='test')>()
> E + where <bound method Signature.apply of
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args(place_holder='test')>
> =
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args(place_holder='test').apply
> E + where
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args(place_holder='test')
> = <bound method Task.si of <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args of celery.tests
> at 0x7f6823608820>>(place_holder='test')
> E + where <bound method Task.si of <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args of celery.tests
> at 0x7f6823608820>> = <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args of celery.tests
> at 0x7f6823608820>.si
> E + where <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_with_new_args of celery.tests
> at 0x7f6823608820> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682b751b40>.retry_task_auto_retry_with_new_args
>
> t/unit/tasks/test_tasks.py:457: AssertionError
> _______ test_task_retries.test_eager_retry_with_autoretry_for_exception
> ________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b751570>
>
> def test_eager_retry_with_autoretry_for_exception(self):
> > assert
> > self.retry_task_auto_retry_exception_with_new_args.si(place_holder="test").apply().get()
> > == "test"
> E AssertionError: assert None == 'test'
> E + where None = <bound method EagerResult.get of <EagerResult:
> 679d3763-e1ff-472c-b1fd-dc681264dbaf>>()
> E + where <bound method EagerResult.get of <EagerResult:
> 679d3763-e1ff-472c-b1fd-dc681264dbaf>> = <EagerResult:
> 679d3763-e1ff-472c-b1fd-dc681264dbaf>.get
> E + where <EagerResult: 679d3763-e1ff-472c-b1fd-dc681264dbaf> =
> <bound method Signature.apply of
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args(place_holder='test')>()
> E + where <bound method Signature.apply of
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args(place_holder='test')>
> =
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args(place_holder='test').apply
> E + where
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args(place_holder='test')
> = <bound method Task.si of <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args of
> celery.tests at 0x7f682320dff0>>(place_holder='test')
> E + where <bound method Task.si of <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args of
> celery.tests at 0x7f682320dff0>> = <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args of
> celery.tests at 0x7f682320dff0>.si
> E + where <@task:
> t.unit.tasks.test_tasks.retry_task_auto_retry_exception_with_new_args of
> celery.tests at 0x7f682320dff0> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682b751570>.retry_task_auto_retry_exception_with_new_args
>
> t/unit/tasks/test_tasks.py:460: AssertionError
> ____________ test_task_retries.test_retry_task_max_retries_override
> ____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b971de0>
>
> def test_retry_task_max_retries_override(self):
> self.retry_task_max_retries_override.max_retries = 10
> self.retry_task_max_retries_override.iterations = 0
> result = self.retry_task_max_retries_override.apply()
> > with pytest.raises(MyCustomException):
> E Failed: DID NOT RAISE <class
> 't.unit.tasks.test_tasks.MyCustomException'>
>
> t/unit/tasks/test_tasks.py:466: Failed
> _____________ test_task_retries.test_retry_task_explicit_exception
> _____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b8cba30>
>
> def test_retry_task_explicit_exception(self):
> self.retry_task_explicit_exception.max_retries = 0
> self.retry_task_explicit_exception.iterations = 0
> result = self.retry_task_explicit_exception.apply()
> with pytest.raises(MyCustomException):
> > result.get()
>
> t/unit/tasks/test_tasks.py:475:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <EagerResult: 68877823-15e8-40de-9b0b-9e2c706aa632>, timeout = None
> propagate = True, disable_sync_subtasks = True, kwargs = {}
>
> def get(self, timeout=None, propagate=True,
> disable_sync_subtasks=True, **kwargs):
> if disable_sync_subtasks:
> assert_will_not_block()
>
> if self.successful():
> return self.result
> elif self.state in states.PROPAGATE_STATES:
> if propagate:
> > raise self.result if isinstance(
> self.result, Exception) else Exception(self.result)
> E billiard.einfo.ExceptionWithTraceback:
> E """
> E Traceback (most recent call last):
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> E R = retval = fun(*args, **kwargs)
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/autoretry.py",
> line 54, in run
> E ret = task.retry(exc=exc, **retry_kwargs)
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/task.py",
> line 717, in retry
> E raise_with_context(exc)
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/autoretry.py",
> line 34, in run
> E return task._orig_run(*args, **kwargs)
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py",
> line 164, in retry_task_explicit_exception
> E raise MyCustomException()
> E t.unit.tasks.test_tasks.MyCustomException
> E """
>
> celery/result.py:1005: ExceptionWithTraceback
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.app.trace:trace.py:265 Task
> t.unit.tasks.test_tasks.retry_task_explicit_exception[68877823-15e8-40de-9b0b-9e2c706aa632]
> raised unexpected: ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/autoretry.py",
> line 54, in run
> ret = task.retry(exc=exc, **retry_kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/task.py",
> line 717, in retry
> raise_with_context(exc)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/autoretry.py",
> line 34, in run
> return task._orig_run(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py",
> line 164, in retry_task_explicit_exception
> raise MyCustomException()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/autoretry.py",
> line 54, in run
> ret = task.retry(exc=exc, **retry_kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/task.py",
> line 717, in retry
> raise_with_context(exc)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/autoretry.py",
> line 34, in run
> return task._orig_run(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py",
> line 164, in retry_task_explicit_exception
> raise MyCustomException()
> t.unit.tasks.test_tasks.MyCustomException
> """
> ____________ test_task_retries.test_retry_eager_should_return_value
> ____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b8cb910>
>
> def test_retry_eager_should_return_value(self):
> self.retry_task.max_retries = 3
> self.retry_task.iterations = 0
> > assert self.retry_task.apply([0xFF, 0xFFFF]).get() == 0xFF
> E assert None == 255
> E + where None = <bound method EagerResult.get of <EagerResult:
> a19442cc-e785-436f-a48d-c1c60653eddc>>()
> E + where <bound method EagerResult.get of <EagerResult:
> a19442cc-e785-436f-a48d-c1c60653eddc>> = <EagerResult:
> a19442cc-e785-436f-a48d-c1c60653eddc>.get
> E + where <EagerResult: a19442cc-e785-436f-a48d-c1c60653eddc> =
> <bound method Task.apply of <@task: t.unit.tasks.test_tasks.retry_task of
> celery.tests at 0x7f68233dae00>>([255, 65535])
> E + where <bound method Task.apply of <@task:
> t.unit.tasks.test_tasks.retry_task of celery.tests at 0x7f68233dae00>> =
> <@task: t.unit.tasks.test_tasks.retry_task of celery.tests at
> 0x7f68233dae00>.apply
> E + where <@task: t.unit.tasks.test_tasks.retry_task of
> celery.tests at 0x7f68233dae00> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682b8cb910>.retry_task
>
> t/unit/tasks/test_tasks.py:481: AssertionError
> ___________________ test_task_retries.test_retry_with_kwargs
> ___________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b8caf50>
>
> def test_retry_with_kwargs(self):
> self.retry_task_customexc.max_retries = 3
> self.retry_task_customexc.iterations = 0
> self.retry_task_customexc.apply([0xFF, 0xFFFF], {'kwarg': 0xF})
> > assert self.retry_task_customexc.iterations == 4
> E assert 1 == 4
> E + where 1 = <@task: t.unit.tasks.test_tasks.retry_task_customexc of
> celery.tests at 0x7f682349b880>.iterations
> E + where <@task: t.unit.tasks.test_tasks.retry_task_customexc of
> celery.tests at 0x7f682349b880> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682b8caf50>.retry_task_customexc
>
> t/unit/tasks/test_tasks.py:513: AssertionError
> ______________ test_task_retries.test_retry_with_custom_exception
> ______________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b8cae60>
>
> def test_retry_with_custom_exception(self):
> self.retry_task_customexc.max_retries = 2
> self.retry_task_customexc.iterations = 0
> result = self.retry_task_customexc.apply(
> [0xFF, 0xFFFF], {'kwarg': 0xF},
> )
> > with pytest.raises(MyCustomException):
> E Failed: DID NOT RAISE <class
> 't.unit.tasks.test_tasks.MyCustomException'>
>
> t/unit/tasks/test_tasks.py:521: Failed
> _________________ test_task_retries.test_max_retries_exceeded
> __________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b8caaa0>
>
> def test_max_retries_exceeded(self):
> self.retry_task.max_retries = 2
> self.retry_task.iterations = 0
> result = self.retry_task.apply([0xFF, 0xFFFF], {'care': False})
> > with pytest.raises(self.retry_task.MaxRetriesExceededError):
> E Failed: DID NOT RAISE <class
> 'celery.exceptions.MaxRetriesExceededError'>
>
> t/unit/tasks/test_tasks.py:529: Failed
> ____________ test_task_retries.test_max_retries_exceeded_task_args
> _____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6e7a0>
>
> def test_max_retries_exceeded_task_args(self):
> self.retry_task.max_retries = 2
> self.retry_task.iterations = 0
> args = (0xFF, 0xFFFF)
> kwargs = {'care': False}
> result = self.retry_task.apply(args, kwargs)
> > with pytest.raises(self.retry_task.MaxRetriesExceededError) as e:
> E Failed: DID NOT RAISE <class
> 'celery.exceptions.MaxRetriesExceededError'>
>
> t/unit/tasks/test_tasks.py:546: Failed
> __________________ test_task_retries.test_autoretry_no_kwargs
> __________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6f0d0>
>
> def test_autoretry_no_kwargs(self):
> self.autoretry_task_no_kwargs.max_retries = 3
> self.autoretry_task_no_kwargs.iterations = 0
> self.autoretry_task_no_kwargs.apply((1, 0))
> > assert self.autoretry_task_no_kwargs.iterations == 4
> E assert 1 == 4
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.autoretry_task_no_kwargs of celery.tests at
> 0x7f68233d3520>.iterations
> E + where <@task: t.unit.tasks.test_tasks.autoretry_task_no_kwargs
> of celery.tests at 0x7f68233d3520> =
> <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682bf6f0d0>.autoretry_task_no_kwargs
>
> t/unit/tasks/test_tasks.py:556: AssertionError
> _______________________ test_task_retries.test_autoretry
> _______________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6eb60>
>
> def test_autoretry(self):
> self.autoretry_task.max_retries = 3
> self.autoretry_task.iterations = 0
> self.autoretry_task.apply((1, 0))
> > assert self.autoretry_task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task: t.unit.tasks.test_tasks.autoretry_task of
> celery.tests at 0x7f6823103b80>.iterations
> E + where <@task: t.unit.tasks.test_tasks.autoretry_task of
> celery.tests at 0x7f6823103b80> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682bf6eb60>.autoretry_task
>
> t/unit/tasks/test_tasks.py:562: AssertionError
> ___________________ test_task_retries.test_autoretry_backoff
> ___________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b7533d0>
> randrange = <MagicMock name='randrange' id='140085242556480'>
>
> @patch('random.randrange', side_effect=lambda i: i - 1)
> def test_autoretry_backoff(self, randrange):
> task = self.autoretry_backoff_task
> task.max_retries = 3
> task.iterations = 0
>
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply(("http://httpbin.org/error";,))
>
> > assert task.iterations == 4
> E assert 1 == 4
> E + where 1 = <@task: t.unit.tasks.test_tasks.autoretry_backoff_task
> of celery.tests at 0x7f6823103ca0>.iterations
>
> t/unit/tasks/test_tasks.py:573: AssertionError
> _______________ test_task_retries.test_autoretry_backoff_jitter
> ________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682b751de0>
> randrange = <MagicMock name='randrange' id='140085241834336'>
>
> @patch('random.randrange', side_effect=lambda i: i - 2)
> def test_autoretry_backoff_jitter(self, randrange):
> task = self.autoretry_backoff_jitter_task
> task.max_retries = 3
> task.iterations = 0
>
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply(("http://httpbin.org/error";,))
>
> > assert task.iterations == 4
> E assert 1 == 4
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.autoretry_backoff_jitter_task of celery.tests at
> 0x7f6823102590>.iterations
>
> t/unit/tasks/test_tasks.py:588: AssertionError
> ________________ test_task_retries.test_autoretry_for_from_base
> ________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6f790>
>
> def test_autoretry_for_from_base(self):
> self.autoretry_for_from_base_task.iterations = 0
> self.autoretry_for_from_base_task.apply((1, "a"))
> > assert self.autoretry_for_from_base_task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.autoretry_for_from_base_task of celery.tests at
> 0x7f682313fd60>.iterations
> E + where <@task:
> t.unit.tasks.test_tasks.autoretry_for_from_base_task of celery.tests at
> 0x7f682313fd60> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682bf6f790>.autoretry_for_from_base_task
>
> t/unit/tasks/test_tasks.py:597: AssertionError
> ___________ test_task_retries.test_override_autoretry_for_from_base
> ____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6faf0>
>
> def test_override_autoretry_for_from_base(self):
> self.override_autoretry_for.iterations = 0
> self.override_autoretry_for.apply((1, 0))
> > assert self.override_autoretry_for.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.override_autoretry_for_from_base_task of celery.tests
> at 0x7f6823170e20>.iterations
> E + where <@task:
> t.unit.tasks.test_tasks.override_autoretry_for_from_base_task of celery.tests
> at 0x7f6823170e20> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682bf6faf0>.override_autoretry_for
>
> t/unit/tasks/test_tasks.py:602: AssertionError
> ________________ test_task_retries.test_retry_kwargs_from_base
> _________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6f970>
>
> def test_retry_kwargs_from_base(self):
> self.retry_kwargs_from_base_task.iterations = 0
> self.retry_kwargs_from_base_task.apply((1, "a"))
> > assert self.retry_kwargs_from_base_task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.retry_kwargs_from_base_task of celery.tests at
> 0x7f6823170dc0>.iterations
> E + where <@task:
> t.unit.tasks.test_tasks.retry_kwargs_from_base_task of celery.tests at
> 0x7f6823170dc0> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682bf6f970>.retry_kwargs_from_base_task
>
> t/unit/tasks/test_tasks.py:607: AssertionError
> ____________ test_task_retries.test_override_retry_kwargs_from_base
> ____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6ffa0>
>
> def test_override_retry_kwargs_from_base(self):
> self.override_retry_kwargs.iterations = 0
> self.override_retry_kwargs.apply((1, "a"))
> > assert self.override_retry_kwargs.iterations == 3
> E assert 1 == 3
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.override_retry_kwargs_from_base_task of celery.tests
> at 0x7f6823170070>.iterations
> E + where <@task:
> t.unit.tasks.test_tasks.override_retry_kwargs_from_base_task of celery.tests
> at 0x7f6823170070> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682bf6ffa0>.override_retry_kwargs
>
> t/unit/tasks/test_tasks.py:612: AssertionError
> ________________ test_task_retries.test_retry_backoff_from_base
> ________________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6f6d0>
>
> def test_retry_backoff_from_base(self):
> task = self.retry_backoff_from_base_task
> task.iterations = 0
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply((1, "a"))
>
> > assert task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.retry_backoff_from_base_task of celery.tests at
> 0x7f68231843a0>.iterations
>
> t/unit/tasks/test_tasks.py:620: AssertionError
> ___________ test_task_retries.test_override_retry_backoff_from_base
> ____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6f730>
> backoff = <MagicMock name='get_exponential_backoff_interval'
> id='140085242472448'>
>
> @patch('celery.app.autoretry.get_exponential_backoff_interval')
> def test_override_retry_backoff_from_base(self, backoff):
> self.override_retry_backoff.iterations = 0
> self.override_retry_backoff.apply((1, "a"))
> > assert self.override_retry_backoff.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.override_retry_backoff_from_base_task of celery.tests
> at 0x7f6823185f90>.iterations
> E + where <@task:
> t.unit.tasks.test_tasks.override_retry_backoff_from_base_task of celery.tests
> at 0x7f6823185f90> = <t.unit.tasks.test_tasks.test_task_retries object at
> 0x7f682bf6f730>.override_retry_backoff
>
> t/unit/tasks/test_tasks.py:630: AssertionError
> ______________ test_task_retries.test_retry_backoff_max_from_base
> ______________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6cd00>
>
> def test_retry_backoff_max_from_base(self):
> task = self.retry_backoff_max_from_base_task
> task.iterations = 0
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply((1, "a"))
>
> > assert task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.retry_backoff_max_from_base_task of celery.tests at
> 0x7f6823187250>.iterations
>
> t/unit/tasks/test_tasks.py:639: AssertionError
> _________ test_task_retries.test_override_retry_backoff_max_from_base
> __________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6cc40>
>
> def test_override_retry_backoff_max_from_base(self):
> task = self.override_backoff_max
> task.iterations = 0
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply((1, "a"))
>
> > assert task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.override_retry_backoff_max_from_base_task of
> celery.tests at 0x7f68231fe200>.iterations
>
> t/unit/tasks/test_tasks.py:651: AssertionError
> ____________ test_task_retries.test_retry_backoff_jitter_from_base
> _____________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6e200>
>
> def test_retry_backoff_jitter_from_base(self):
> task = self.retry_backoff_jitter_from_base
> task.iterations = 0
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply((1, "a"))
>
> > assert task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.retry_backoff_jitter_from_base_task of celery.tests
> at 0x7f682317fca0>.iterations
>
> t/unit/tasks/test_tasks.py:663: AssertionError
> ___________ test_task_retries.test_override_backoff_jitter_from_base
> ___________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6e260>
> randrange = <MagicMock name='randrange' id='140085241658864'>
>
> @patch('random.randrange', side_effect=lambda i: i - 2)
> def test_override_backoff_jitter_from_base(self, randrange):
> task = self.override_backoff_jitter
> task.iterations = 0
> with patch.object(task, 'retry', wraps=task.retry) as fake_retry:
> task.apply((1, "a"))
>
> > assert task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task:
> t.unit.tasks.test_tasks.override_backoff_jitter_from_base_task of
> celery.tests at 0x7f6823182b90>.iterations
>
> t/unit/tasks/test_tasks.py:676: AssertionError
> __________ test_task_retries.test_retry_wrong_eta_when_not_enable_utc
> __________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6d660>
>
> def test_retry_wrong_eta_when_not_enable_utc(self):
> """Issue #3753"""
> self.app.conf.enable_utc = False
> self.app.conf.timezone = 'US/Eastern'
> self.autoretry_task.iterations = 0
> self.autoretry_task.default_retry_delay = 2
>
> self.autoretry_task.apply((1, 0))
> > assert self.autoretry_task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task: t.unit.tasks.test_tasks.autoretry_task of
> celery.tests at 0x7f6823113910>.iterations
> E + where <@task: t.unit.tasks.test_tasks.autoretry_task of
> celery.tests at 0x7f6823113910> = <t.unit.tasks.test_tasks.test_task_retries
> object at 0x7f682bf6d660>.autoretry_task
>
> t/unit/tasks/test_tasks.py:690: AssertionError
> ______________ test_task_retries.test_autoretry_class_based_task
> _______________
>
> self = <t.unit.tasks.test_tasks.test_task_retries object at 0x7f682bf6db40>
>
> def test_autoretry_class_based_task(self):
> class ClassBasedAutoRetryTask(Task):
> name = 'ClassBasedAutoRetryTask'
> autoretry_for = (ZeroDivisionError,)
> retry_kwargs = {'max_retries': 5}
> retry_backoff = True
> retry_backoff_max = 700
> retry_jitter = False
> iterations = 0
> _app = self.app
>
> def run(self, x, y):
> self.iterations += 1
> return x / y
>
> task = ClassBasedAutoRetryTask()
> self.app.tasks.register(task)
> task.iterations = 0
> task.apply([1, 0])
> > assert task.iterations == 6
> E assert 1 == 6
> E + where 1 = <@task: ClassBasedAutoRetryTask of celery.tests at
> 0x7f68234e53f0>.iterations
>
> t/unit/tasks/test_tasks.py:711: AssertionError
> __________________________ test_apply_task.test_apply
> __________________________
>
> self = <t.unit.tasks.test_tasks.test_apply_task object at 0x7f682b6cc760>
>
> def test_apply(self):
> self.increment_counter.count = 0
>
> e = self.increment_counter.apply()
> assert isinstance(e, EagerResult)
> assert e.get() == 1
>
> e = self.increment_counter.apply(args=[1])
> assert e.get() == 2
>
> e = self.increment_counter.apply(kwargs={'increment_by': 4})
> assert e.get() == 6
>
> assert e.successful()
> assert e.ready()
> assert repr(e).startswith('<EagerResult:')
>
> f = self.raising.apply()
> assert f.ready()
> assert not f.successful()
> assert f.traceback
> with pytest.raises(KeyError):
> > f.get()
>
> t/unit/tasks/test_tasks.py:1322:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <EagerResult: 1eb9ed63-1d65-4e22-b007-bc2d60e6139c>, timeout = None
> propagate = True, disable_sync_subtasks = True, kwargs = {}
>
> def get(self, timeout=None, propagate=True,
> disable_sync_subtasks=True, **kwargs):
> if disable_sync_subtasks:
> assert_will_not_block()
>
> if self.successful():
> return self.result
> elif self.state in states.PROPAGATE_STATES:
> if propagate:
> > raise self.result if isinstance(
> self.result, Exception) else Exception(self.result)
> E billiard.einfo.ExceptionWithTraceback:
> E """
> E Traceback (most recent call last):
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> E R = retval = fun(*args, **kwargs)
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py",
> line 65, in raising
> E raise KeyError('foo')
> E KeyError: 'foo'
> E """
>
> celery/result.py:1005: ExceptionWithTraceback
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.app.trace:trace.py:265 Task
> t.unit.tasks.test_tasks.raising[1eb9ed63-1d65-4e22-b007-bc2d60e6139c] raised
> unexpected: ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py",
> line 65, in raising
> raise KeyError('foo')
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py",
> line 65, in raising
> raise KeyError('foo')
> KeyError: 'foo'
> """
> ____________________ test_ExceptionInfo.test_exception_info
> ____________________
>
> self = <t.unit.utils.test_collections.test_ExceptionInfo object at
> 0x7f682beb67d0>
>
> def test_exception_info(self):
>
> try:
> > raise LookupError('The quick brown fox jumps...')
> E LookupError: The quick brown fox jumps...
>
> t/unit/utils/test_collections.py:145: LookupError
>
> During handling of the above exception, another exception occurred:
>
> self = <t.unit.utils.test_collections.test_ExceptionInfo object at
> 0x7f682beb67d0>
>
> def test_exception_info(self):
>
> try:
> raise LookupError('The quick brown fox jumps...')
> except Exception:
> einfo = ExceptionInfo()
> assert str(einfo) == einfo.traceback
> > assert isinstance(einfo.exception, LookupError)
> E assert False
> E + where False = isinstance(ExceptionWithTraceback(),
> LookupError)
> E + where ExceptionWithTraceback() = <ExceptionInfo:
> ExceptionWithTraceback()>.exception
>
> t/unit/utils/test_collections.py:149: AssertionError
> __________________ test_trace_task.test_execute_jail_failure
> ___________________
>
> self = <t.unit.worker.test_request.test_trace_task object at 0x7f682b7f52a0>
>
> def test_execute_jail_failure(self):
> ret = jail(
> self.app, uuid(), self.mytask_raising.name, {}, [4], {},
> )
> assert isinstance(ret, ExceptionInfo)
> > assert ret.exception.args == (4,)
> E assert () == (4,)
> E Right contains one more item: 4
> E Use -v to get more diff
>
> t/unit/worker/test_request.py:161: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.app.trace:trace.py:265 Task
> t.unit.worker.test_request.mytask_raising[1945eb84-7660-480a-9217-9175a5f97bf4]
> raised unexpected: ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 49, in mytask_raising
> raise KeyError(i)
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 451, in trace_task
> R = retval = fun(*args, **kwargs)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 49, in mytask_raising
> raise KeyError(i)
> KeyError: 4
> """
> ___________________ test_Request.test_on_failure_Terminated
> ____________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcb9480>
>
> def test_on_failure_Terminated(self):
> einfo = None
> try:
> raise Terminated('9')
> except Terminated:
> einfo = ExceptionInfo()
> assert einfo is not None
> req = self.get_request(self.add.s(2, 2))
> req.on_failure(einfo)
> > req.eventer.send.assert_called_with(
> 'task-revoked',
> uuid=req.id, terminated=True, signum='9', expired=False,
> )
>
> t/unit/worker/test_request.py:286:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='eventer.send' id='140085220214192'>, args =
> ('task-revoked',)
> kwargs = {'expired': False, 'signum': '9', 'terminated': True, 'uuid':
> 'c1354840-537d-4241-8ae9-580991ef5a62'}
> expected = call('task-revoked', uuid='c1354840-537d-4241-8ae9-580991ef5a62',
> terminated=True, signum='9', expired=False)
> actual = call('task-failed', uuid='c1354840-537d-4241-8ae9-580991ef5a62',
> exception='ExceptionWithTraceback()', traceback='Trac...equest.py", line 280,
> in test_on_failure_Terminated\n raise
> Terminated(\'9\')\nbilliard.exceptions.Terminated: 9\n')
> _error_message = <function
> NonCallableMock.assert_called_with.<locals>._error_message at 0x7f6821c88700>
> cause = None
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> raise AssertionError(error_message)
>
> def _error_message():
> msg = self._format_mock_failure_message(args, kwargs)
> return msg
> expected = self._call_matcher(_Call((args, kwargs), two=True))
> actual = self._call_matcher(self.call_args)
> if actual != expected:
> cause = expected if isinstance(expected, Exception) else None
> > raise AssertionError(_error_message()) from cause
> E AssertionError: expected call not found.
> E Expected: send('task-revoked',
> uuid='c1354840-537d-4241-8ae9-580991ef5a62', terminated=True, signum='9',
> expired=False)
> E Actual: send('task-failed',
> uuid='c1354840-537d-4241-8ae9-580991ef5a62',
> exception='ExceptionWithTraceback()', traceback='Traceback (most recent call
> last):\n File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 280, in test_on_failure_Terminated\n raise
> Terminated(\'9\')\nbilliard.exceptions.Terminated: 9\n')
>
> /usr/lib/python3.10/unittest/mock.py:919: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 280, in test_on_failure_Terminated
> raise Terminated('9')
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 280, in test_on_failure_Terminated
> raise Terminated('9')
> billiard.exceptions.Terminated: 9
> """
> _____________ test_Request.test_on_failure_propagates_MemoryError
> ______________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcb97b0>
>
> def test_on_failure_propagates_MemoryError(self):
> einfo = None
> try:
> raise MemoryError()
> except MemoryError:
> einfo = ExceptionInfo(internal=True)
> assert einfo is not None
> req = self.get_request(self.add.s(2, 2))
> > with pytest.raises(MemoryError):
> E Failed: DID NOT RAISE <class 'MemoryError'>
>
> t/unit/worker/test_request.py:299: Failed
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 294, in test_on_failure_propagates_MemoryError
> raise MemoryError()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 294, in test_on_failure_propagates_MemoryError
> raise MemoryError()
> MemoryError
> """
> _______________ test_Request.test_on_failure_Ignore_acknowledges
> _______________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcb9b40>
>
> def test_on_failure_Ignore_acknowledges(self):
> einfo = None
> try:
> raise Ignore()
> except Ignore:
> einfo = ExceptionInfo(internal=True)
> assert einfo is not None
> req = self.get_request(self.add.s(2, 2))
> req.on_failure(einfo)
> > req.on_ack.assert_called_with(req_logger, req.connection_errors)
>
> t/unit/worker/test_request.py:311:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='on_ack' id='140085219738480'>
> args = (<Logger celery.worker.request (WARNING)>, (<class 'OSError'>,))
> kwargs = {}
> expected = "on_ack(<Logger celery.worker.request (WARNING)>, (<class
> 'OSError'>,))"
> actual = 'not called.'
> error_message = "expected call not found.\nExpected: on_ack(<Logger
> celery.worker.request (WARNING)>, (<class 'OSError'>,))\nActual: not called."
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> > raise AssertionError(error_message)
> E AssertionError: expected call not found.
> E Expected: on_ack(<Logger celery.worker.request (WARNING)>,
> (<class 'OSError'>,))
> E Actual: not called.
>
> /usr/lib/python3.10/unittest/mock.py:910: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 305, in test_on_failure_Ignore_acknowledges
> raise Ignore()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 305, in test_on_failure_Ignore_acknowledges
> raise Ignore()
> celery.exceptions.Ignore
> """
> _________________ test_Request.test_on_failure_Reject_rejects
> __________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcb9ed0>
>
> def test_on_failure_Reject_rejects(self):
> einfo = None
> try:
> raise Reject()
> except Reject:
> einfo = ExceptionInfo(internal=True)
> assert einfo is not None
> req = self.get_request(self.add.s(2, 2))
> req.on_failure(einfo)
> > req.on_reject.assert_called_with(
> req_logger, req.connection_errors, False,
> )
>
> t/unit/worker/test_request.py:322:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='on_reject' id='140085217791232'>
> args = (<Logger celery.worker.request (WARNING)>, (<class 'OSError'>,), False)
> kwargs = {}
> expected = "on_reject(<Logger celery.worker.request (WARNING)>, (<class
> 'OSError'>,), False)"
> actual = 'not called.'
> error_message = "expected call not found.\nExpected: on_reject(<Logger
> celery.worker.request (WARNING)>, (<class 'OSError'>,), False)\nActual: not
> called."
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> > raise AssertionError(error_message)
> E AssertionError: expected call not found.
> E Expected: on_reject(<Logger celery.worker.request (WARNING)>,
> (<class 'OSError'>,), False)
> E Actual: not called.
>
> /usr/lib/python3.10/unittest/mock.py:910: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 316, in test_on_failure_Reject_rejects
> raise Reject()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 316, in test_on_failure_Reject_rejects
> raise Reject()
> celery.exceptions.Reject: (None, False)
> """
> ___________ test_Request.test_on_failure_Reject_rejects_with_requeue
> ___________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcbab00>
>
> def test_on_failure_Reject_rejects_with_requeue(self):
> einfo = None
> try:
> raise Reject(requeue=True)
> except Reject:
> einfo = ExceptionInfo(internal=True)
> assert einfo is not None
> req = self.get_request(self.add.s(2, 2))
> req.on_failure(einfo)
> > req.on_reject.assert_called_with(
> req_logger, req.connection_errors, True,
> )
>
> t/unit/worker/test_request.py:335:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='on_reject' id='140085221836304'>
> args = (<Logger celery.worker.request (WARNING)>, (<class 'OSError'>,), True)
> kwargs = {}
> expected = "on_reject(<Logger celery.worker.request (WARNING)>, (<class
> 'OSError'>,), True)"
> actual = 'not called.'
> error_message = "expected call not found.\nExpected: on_reject(<Logger
> celery.worker.request (WARNING)>, (<class 'OSError'>,), True)\nActual: not
> called."
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> > raise AssertionError(error_message)
> E AssertionError: expected call not found.
> E Expected: on_reject(<Logger celery.worker.request (WARNING)>,
> (<class 'OSError'>,), True)
> E Actual: not called.
>
> /usr/lib/python3.10/unittest/mock.py:910: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 329, in test_on_failure_Reject_rejects_with_requeue
> raise Reject(requeue=True)
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 329, in test_on_failure_Reject_rejects_with_requeue
> raise Reject(requeue=True)
> celery.exceptions.Reject: (None, True)
> """
> ______ test_Request.test_on_failure_WorkerLostError_rejects_with_requeue
> _______
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcb8b80>
>
> def test_on_failure_WorkerLostError_rejects_with_requeue(self):
> try:
> raise WorkerLostError()
> except WorkerLostError:
> einfo = ExceptionInfo(internal=True)
>
> req = self.get_request(self.add.s(2, 2))
> req.task.acks_late = True
> req.task.reject_on_worker_lost = True
> req.delivery_info['redelivered'] = False
> req.task.backend = Mock()
>
> req.on_failure(einfo)
>
> > req.on_reject.assert_called_with(
> req_logger, req.connection_errors, True)
>
> t/unit/worker/test_request.py:353:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='on_reject' id='140085220227392'>
> args = (<Logger celery.worker.request (WARNING)>, (<class 'OSError'>,), True)
> kwargs = {}
> expected = "on_reject(<Logger celery.worker.request (WARNING)>, (<class
> 'OSError'>,), True)"
> actual = 'not called.'
> error_message = "expected call not found.\nExpected: on_reject(<Logger
> celery.worker.request (WARNING)>, (<class 'OSError'>,), True)\nActual: not
> called."
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> > raise AssertionError(error_message)
> E AssertionError: expected call not found.
> E Expected: on_reject(<Logger celery.worker.request (WARNING)>,
> (<class 'OSError'>,), True)
> E Actual: not called.
>
> /usr/lib/python3.10/unittest/mock.py:910: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 341, in test_on_failure_WorkerLostError_rejects_with_requeue
> raise WorkerLostError()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 341, in test_on_failure_WorkerLostError_rejects_with_requeue
> raise WorkerLostError()
> billiard.exceptions.WorkerLostError
> """
> ________ test_Request.test_on_failure_WorkerLostError_redelivered_None
> _________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682bcba4a0>
>
> def test_on_failure_WorkerLostError_redelivered_None(self):
> try:
> raise WorkerLostError()
> except WorkerLostError:
> einfo = ExceptionInfo(internal=True)
>
> req = self.get_request(self.add.s(2, 2))
> req.task.acks_late = True
> req.task.reject_on_worker_lost = True
> req.delivery_info['redelivered'] = None
> req.task.backend = Mock()
>
> req.on_failure(einfo)
>
> > req.on_reject.assert_called_with(
> req_logger, req.connection_errors, True)
>
> t/unit/worker/test_request.py:371:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='on_reject' id='140085223368800'>
> args = (<Logger celery.worker.request (WARNING)>, (<class 'OSError'>,), True)
> kwargs = {}
> expected = "on_reject(<Logger celery.worker.request (WARNING)>, (<class
> 'OSError'>,), True)"
> actual = 'not called.'
> error_message = "expected call not found.\nExpected: on_reject(<Logger
> celery.worker.request (WARNING)>, (<class 'OSError'>,), True)\nActual: not
> called."
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> > raise AssertionError(error_message)
> E AssertionError: expected call not found.
> E Expected: on_reject(<Logger celery.worker.request (WARNING)>,
> (<class 'OSError'>,), True)
> E Actual: not called.
>
> /usr/lib/python3.10/unittest/mock.py:910: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 359, in test_on_failure_WorkerLostError_redelivered_None
> raise WorkerLostError()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 359, in test_on_failure_WorkerLostError_redelivered_None
> raise WorkerLostError()
> billiard.exceptions.WorkerLostError
> """
> __________________________ test_Request.test_on_retry
> __________________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682be10a00>
>
> def test_on_retry(self):
> job = self.get_request(self.mytask.s(1, f='x'))
> job.eventer = Mock(name='.eventer')
> try:
> raise Retry('foo', KeyError('moofoobar'))
> except Retry:
> einfo = ExceptionInfo()
> job.on_failure(einfo)
> > job.eventer.send.assert_called_with(
> 'task-retried',
> uuid=job.id,
> exception=safe_repr(einfo.exception.exc),
> traceback=safe_str(einfo.traceback),
> )
>
> t/unit/worker/test_request.py:442:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='.eventer.send' id='140085213957328'>
> args = ('task-retried',)
> kwargs = {'exception': "Retry(Retry(...), KeyError('moofoobar'), None)",
> 'traceback': 'Traceback (most recent call last):\n Fi...try(\'foo\',
> KeyError(\'moofoobar\'))\ncelery.exceptions.Retry: foo\n', 'uuid':
> '27dbf61e-36e7-4f0e-b261-8a6a716f4852'}
> expected = call('task-retried', uuid='27dbf61e-36e7-4f0e-b261-8a6a716f4852',
> exception="Retry(Retry(...), KeyError('moofoobar'), ...st.py", line 438, in
> test_on_retry\n raise Retry(\'foo\',
> KeyError(\'moofoobar\'))\ncelery.exceptions.Retry: foo\n')
> actual = call('task-failed', uuid='27dbf61e-36e7-4f0e-b261-8a6a716f4852',
> exception='ExceptionWithTraceback()', traceback='Trac...st.py", line 438, in
> test_on_retry\n raise Retry(\'foo\',
> KeyError(\'moofoobar\'))\ncelery.exceptions.Retry: foo\n')
> _error_message = <function
> NonCallableMock.assert_called_with.<locals>._error_message at 0x7f6821619480>
> cause = None
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> raise AssertionError(error_message)
>
> def _error_message():
> msg = self._format_mock_failure_message(args, kwargs)
> return msg
> expected = self._call_matcher(_Call((args, kwargs), two=True))
> actual = self._call_matcher(self.call_args)
> if actual != expected:
> cause = expected if isinstance(expected, Exception) else None
> > raise AssertionError(_error_message()) from cause
> E AssertionError: expected call not found.
> E Expected: send('task-retried',
> uuid='27dbf61e-36e7-4f0e-b261-8a6a716f4852', exception="Retry(Retry(...),
> KeyError('moofoobar'), None)", traceback='Traceback (most recent call
> last):\n File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 438, in test_on_retry\n raise Retry(\'foo\',
> KeyError(\'moofoobar\'))\ncelery.exceptions.Retry: foo\n')
> E Actual: send('task-failed',
> uuid='27dbf61e-36e7-4f0e-b261-8a6a716f4852',
> exception='ExceptionWithTraceback()', traceback='Traceback (most recent call
> last):\n File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 438, in test_on_retry\n raise Retry(\'foo\',
> KeyError(\'moofoobar\'))\ncelery.exceptions.Retry: foo\n')
>
> /usr/lib/python3.10/unittest/mock.py:919: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 438, in test_on_retry
> raise Retry('foo', KeyError('moofoobar'))
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 438, in test_on_retry
> raise Retry('foo', KeyError('moofoobar'))
> celery.exceptions.Retry: foo
> """
> __________________ test_Request.test_on_success_BaseException
> __________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682be54d60>
>
> def test_on_success_BaseException(self):
> job = self.xRequest()
> job.time_start = 1
> > with pytest.raises(SystemExit):
> E Failed: DID NOT RAISE <class 'SystemExit'>
>
> t/unit/worker/test_request.py:653: Failed
> _____ test_Request.test_on_failure_acks_late_reject_on_worker_lost_enabled
> _____
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682be55d80>
>
> def test_on_failure_acks_late_reject_on_worker_lost_enabled(self):
> try:
> raise WorkerLostError()
> except WorkerLostError:
> exc_info = ExceptionInfo()
> self.mytask.acks_late = True
> self.mytask.reject_on_worker_lost = True
>
> job = self.xRequest()
> job.delivery_info['redelivered'] = False
> job.on_failure(exc_info)
>
> > assert self.mytask.backend.get_status(job.id) == states.PENDING
> E AssertionError: assert 'FAILURE' == 'PENDING'
> E - PENDING
> E + FAILURE
>
> t/unit/worker/test_request.py:718: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 708, in test_on_failure_acks_late_reject_on_worker_lost_enabled
> raise WorkerLostError()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 708, in test_on_failure_acks_late_reject_on_worker_lost_enabled
> raise WorkerLostError()
> billiard.exceptions.WorkerLostError
> """
> _________________ test_Request.test_on_failure_task_cancelled
> __________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682be56950>
>
> def test_on_failure_task_cancelled(self):
> job = self.xRequest()
> job.eventer = Mock()
> job.time_start = 1
> job._already_cancelled = True
>
> try:
> raise Terminated()
> except Terminated:
> exc_info = ExceptionInfo()
>
> job.on_failure(exc_info)
>
> job.on_failure(exc_info)
> > assert not job.eventer.send.called
> E AssertionError: assert not True
> E + where True = <Mock name='mock.send' id='140085218437504'>.called
> E + where <Mock name='mock.send' id='140085218437504'> = <Mock
> id='140085218439184'>.send
> E + where <Mock id='140085218439184'> = <Request:
> t.unit.worker.test_request.mytask[6af8bfde-5d9d-4420-bd71-e0b2729d8cbe]
> >.eventer
>
> t/unit/worker/test_request.py:807: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 800, in test_on_failure_task_cancelled
> raise Terminated()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 800, in test_on_failure_task_cancelled
> raise Terminated()
> billiard.exceptions.Terminated
> """
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 800, in test_on_failure_task_cancelled
> raise Terminated()
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 800, in test_on_failure_task_cancelled
> raise Terminated()
> billiard.exceptions.Terminated
> """
> ________________ test_Request.test_from_message_invalid_kwargs
> _________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682be55a50>
>
> def test_from_message_invalid_kwargs(self):
> m = self.TaskMessage(self.mytask.name, args=(), kwargs='foo')
> req = Request(m, app=self.app)
> with pytest.raises(InvalidTaskError):
> > raise req.execute().exception
> E billiard.einfo.ExceptionWithTraceback:
> E """
> E Traceback (most recent call last):
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 401, in trace_task
> E kwargs.items
> E AttributeError: 'str' object has no attribute 'items'
> E
> E During handling of the above exception, another exception
> occurred:
> E
> E Traceback (most recent call last):
> E File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 403, in trace_task
> E raise InvalidTaskError(
> E celery.exceptions.InvalidTaskError: Task keyword arguments is not
> a mapping
> E """
>
> t/unit/worker/test_request.py:813: ExceptionWithTraceback
> ________________ test_Request.test_on_failure__WorkerLostError
> _________________
>
> self = <t.unit.worker.test_request.test_Request object at 0x7f682ba312d0>
>
> def test_on_failure__WorkerLostError(self):
> exc = WorkerLostError()
> job = self._test_on_failure(exc)
> > job.task.backend.mark_as_failure.assert_called_with(
> job.id, exc, request=job._context, store_result=True,
> )
>
> t/unit/worker/test_request.py:1147:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> self = <Mock name='mark_as_failure' id='140085212249872'>
> args = ('e2520ba1-8b13-4655-b8b8-0f8f291b00d3', WorkerLostError())
> kwargs = {'request': <Context: {'id': 'e2520ba1-8b13-4655-b8b8-0f8f291b00d3',
> 'task': 't.unit.worker.test_request.mytask', 'sha...5552'>}, 'args': [4],
> 'kwargs': {'f': 'x'}, 'callbacks': None, 'errbacks': None, 'chain': None}>,
> 'store_result': True}
> expected = call('e2520ba1-8b13-4655-b8b8-0f8f291b00d3', WorkerLostError(),
> request=<Context: {'id': 'e2520ba1-8b13-4655-b8b8-0f8f...2245552'>}, 'args':
> [4], 'kwargs': {'f': 'x'}, 'callbacks': None, 'errbacks': None, 'chain':
> None}>, store_result=True)
> actual = call('e2520ba1-8b13-4655-b8b8-0f8f291b00d3',
> ExceptionWithTraceback(), request=<Context: {'id':
> 'e2520ba1-8b13-4655-b8...2245552'>}, 'args': [4], 'kwargs': {'f': 'x'},
> 'callbacks': None, 'errbacks': None, 'chain': None}>, store_result=True)
> _error_message = <function
> NonCallableMock.assert_called_with.<locals>._error_message at 0x7f6821541000>
> cause = None
>
> def assert_called_with(self, /, *args, **kwargs):
> """assert that the last call was made with the specified arguments.
>
> Raises an AssertionError if the args and keyword args passed in are
> different to the last call to the mock."""
> if self.call_args is None:
> expected = self._format_mock_call_signature(args, kwargs)
> actual = 'not called.'
> error_message = ('expected call not found.\nExpected: %s\nActual:
> %s'
> % (expected, actual))
> raise AssertionError(error_message)
>
> def _error_message():
> msg = self._format_mock_failure_message(args, kwargs)
> return msg
> expected = self._call_matcher(_Call((args, kwargs), two=True))
> actual = self._call_matcher(self.call_args)
> if actual != expected:
> cause = expected if isinstance(expected, Exception) else None
> > raise AssertionError(_error_message()) from cause
> E AssertionError: expected call not found.
> E Expected: mark_as_failure('e2520ba1-8b13-4655-b8b8-0f8f291b00d3',
> WorkerLostError(), request=<Context: {'id':
> 'e2520ba1-8b13-4655-b8b8-0f8f291b00d3', 'task':
> 't.unit.worker.test_request.mytask', 'shadow': None, 'properties': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties'
> id='140085212247520'>, 'reply_to': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties.get()'
> id='140085212248864'>, 'correlation_id': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties.get()'
> id='140085212248864'>, 'hostname': 'ip-10-84-234-121', 'delivery_info':
> {'exchange': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.delivery_info.get()'
> id='140085212245552'>, 'routing_key': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.delivery_info.get()'
> id='140085212245552'>, 'priority': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties.get()'
> id='140085212248864'>, 'redelivered': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.delivery_info.get()'
> id='140085212245552'>}, 'args': [4], 'kwargs': {'f': 'x'}, 'callbacks': None,
> 'errbacks': None, 'chain': None}>, store_result=True)
> E Actual: mark_as_failure('e2520ba1-8b13-4655-b8b8-0f8f291b00d3',
> ExceptionWithTraceback(), request=<Context: {'id':
> 'e2520ba1-8b13-4655-b8b8-0f8f291b00d3', 'task':
> 't.unit.worker.test_request.mytask', 'shadow': None, 'properties': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties'
> id='140085212247520'>, 'reply_to': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties.get()'
> id='140085212248864'>, 'correlation_id': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties.get()'
> id='140085212248864'>, 'hostname': 'ip-10-84-234-121', 'delivery_info':
> {'exchange': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.delivery_info.get()'
> id='140085212245552'>, 'routing_key': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.delivery_info.get()'
> id='140085212245552'>, 'priority': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.properties.get()'
> id='140085212248864'>, 'redelivered': <Mock
> name='TaskMessage-e2520ba1-8b13-4655-b8b8-0f8f291b00d3.delivery_info.get()'
> id='140085212245552'>}, 'args': [4], 'kwargs': {'f': 'x'}, 'callbacks': None,
> 'errbacks': None, 'chain': None}>, store_result=True)
>
> /usr/lib/python3.10/unittest/mock.py:919: AssertionError
> ------------------------------ Captured log call
> -------------------------------
> ERROR celery.worker.request:request.py:596 Task handler raised error:
> ExceptionWithTraceback()
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 1127, in _test_on_failure
> raise exception
> billiard.einfo.ExceptionWithTraceback:
> """
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py",
> line 1127, in _test_on_failure
> raise exception
> billiard.exceptions.WorkerLostError
> """
> ____________ test_create_request_class.test_on_success__SystemExit
> _____________
>
> self = <t.unit.worker.test_request.test_create_request_class object at
> 0x7f682b7b8730>
> errors = (<class 'SystemExit'>, <class 'KeyboardInterrupt'>)
>
> def test_on_success__SystemExit(self,
> errors=(SystemExit, KeyboardInterrupt)):
> for exc in errors:
> einfo = None
> try:
> raise exc()
> except exc:
> einfo = ExceptionInfo()
> > with pytest.raises(exc):
> E Failed: DID NOT RAISE <class 'SystemExit'>
>
> t/unit/worker/test_request.py:1210: Failed
> =============================== warnings summary
> ===============================
> ../../../../../../usr/lib/python3/dist-packages/kombu/utils/compat.py:82
> ../../../../../../usr/lib/python3/dist-packages/kombu/utils/compat.py:82
> /usr/lib/python3/dist-packages/kombu/utils/compat.py:82:
> DeprecationWarning: SelectableGroups dict interface is deprecated. Use select.
> for ep in importlib_metadata.entry_points().get(namespace, [])
>
> ../../../../../../usr/lib/python3/dist-packages/_pytest/config/__init__.py:1252
> /usr/lib/python3/dist-packages/_pytest/config/__init__.py:1252:
> PytestConfigWarning: Unknown config option: xdfail_strict
>
> self._warn_or_fail_if_strict(f"Unknown config option: {key}\n")
>
> celery/utils/imports.py:145: 1 warning
> .pybuild/cpython3_3.10_celery/build/t/unit/test_canvas.py: 2 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_app.py: 6 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_backends.py: 8 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_beat.py: 56 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_builtins.py: 7 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_control.py: 2 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_routes.py: 2 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/backends/test_cache.py: 2 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/backends/test_dynamodb.py: 25
> warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/backends/test_mongodb.py: 7
> warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/backends/test_redis.py: 1 warning
> .pybuild/cpython3_3.10_celery/build/t/unit/contrib/test_abortable.py: 4
> warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_canvas.py: 39 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_chord.py: 9 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_result.py: 94 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_tasks.py: 22 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_trace.py: 21 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/utils/test_graph.py: 9 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_loops.py: 6 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py: 65 warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_strategy.py: 53
> warnings
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_worker.py: 4 warnings
>
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/utils/imports.py:145:
> DeprecationWarning: SelectableGroups dict interface is deprecated. Use
> select.
> for ep in entry_points().get(namespace, []):
>
> .pybuild/cpython3_3.10_celery/build/t/unit/app/test_app.py::test_App::test_worker_main
>
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/bin/celery.py:78:
> DeprecationWarning: SelectableGroups dict interface is deprecated. Use select.
> @with_plugins(entry_points().get('celery.commands', []))
>
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_trace.py::test_trace::test_backend_error_should_report_failure
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py::test_Request::test_execute_backend_error_acks_late
>
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py:660:
> RuntimeWarning: Exception raised outside body: Exception():
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 518, in trace_task
> task.backend.mark_as_done(
> File "/usr/lib/python3.10/unittest/mock.py", line 1104, in __call__
> return self._mock_call(*args, **kwargs)
> File "/usr/lib/python3.10/unittest/mock.py", line 1108, in _mock_call
> return self._execute_mock_call(*args, **kwargs)
> File "/usr/lib/python3.10/unittest/mock.py", line 1163, in
> _execute_mock_call
> raise effect
> Exception
>
> warn(RuntimeWarning(
>
> .pybuild/cpython3_3.10_celery/build/t/unit/tasks/test_trace.py::test_trace::test_backend_error_should_report_failure
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py::test_Request::test_execute_backend_error_acks_late
>
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py:660:
> RuntimeWarning: Exception raised outside body: Exception():
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 518, in trace_task
> task.backend.mark_as_done(
> File "/usr/lib/python3.10/unittest/mock.py", line 1104, in __call__
> return self._mock_call(*args, **kwargs)
> File "/usr/lib/python3.10/unittest/mock.py", line 1108, in _mock_call
> return self._execute_mock_call(*args, **kwargs)
> File "/usr/lib/python3.10/unittest/mock.py", line 1163, in
> _execute_mock_call
> raise effect
> Exception
>
> During handling of the above exception, another exception occurred:
>
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 584, in trace_task
> return task.__trace__(uuid, args, kwargs, request)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 572, in trace_task
> I, _, _, _ = on_error(task_request, exc, uuid)
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 379, in on_error
> R = I.handle_error_state(
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 178, in handle_error_state
> return {
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 225, in handle_failure
> task.backend.mark_as_failure(
> File "/usr/lib/python3.10/unittest/mock.py", line 1104, in __call__
> return self._mock_call(*args, **kwargs)
> File "/usr/lib/python3.10/unittest/mock.py", line 1108, in _mock_call
> return self._execute_mock_call(*args, **kwargs)
> File "/usr/lib/python3.10/unittest/mock.py", line 1163, in
> _execute_mock_call
> raise effect
> Exception
>
> warn(RuntimeWarning(
>
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_consumer.py::test_Consumer::test_collects_at_restart
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_worker.py::test_Consumer::test_start_connection_error
>
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/worker/consumer/consumer.py:367:
> CPendingDeprecationWarning:
> In Celery 5.1 we introduced an optional breaking change which
> on connection loss cancels all currently executed tasks with late
> acknowledgement enabled.
> These tasks cannot be acknowledged as the connection is gone, and the tasks
> are automatically redelivered back to the queue.
> You can enable this behavior using the
> worker_cancel_long_running_tasks_on_connection_loss setting.
> In Celery 5.1 it is set to False by default. The setting will be set to
> True by default in Celery 6.0.
>
> warnings.warn(CANCEL_TASKS_BY_DEFAULT, CPendingDeprecationWarning)
>
> .pybuild/cpython3_3.10_celery/build/t/unit/worker/test_request.py::test_Request::test_from_message_invalid_kwargs
>
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py:660:
> RuntimeWarning: Exception raised outside body: InvalidTaskError('Task keyword
> arguments is not a mapping'):
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 401, in trace_task
> kwargs.items
> AttributeError: 'str' object has no attribute 'items'
>
> During handling of the above exception, another exception occurred:
>
> Traceback (most recent call last):
> File
> "/<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build/celery/app/trace.py",
> line 403, in trace_task
> raise InvalidTaskError(
> celery.exceptions.InvalidTaskError: Task keyword arguments is not a mapping
>
> warn(RuntimeWarning(
>
> -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
> =========================== short test summary info
> ============================
> FAILED t/unit/tasks/test_result.py::test_EagerResult::test_wait_raises -
> bill...
> FAILED t/unit/tasks/test_tasks.py::test_task_retries::test_retry - assert 1
> == 4
> FAILED t/unit/tasks/test_tasks.py::test_task_retries::test_retry_no_args -
> as...
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_raise_without_throw_eager
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_return_with_throw_eager
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_eager_retry_with_single_new_params
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_eager_retry_with_new_params
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_eager_retry_with_autoretry_for_exception
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_task_max_retries_override
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_task_explicit_exception
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_eager_should_return_value
> FAILED t/unit/tasks/test_tasks.py::test_task_retries::test_retry_with_kwargs
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_with_custom_exception
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_max_retries_exceeded
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_max_retries_exceeded_task_args
> FAILED t/unit/tasks/test_tasks.py::test_task_retries::test_autoretry_no_kwargs
> FAILED t/unit/tasks/test_tasks.py::test_task_retries::test_autoretry -
> assert...
> FAILED t/unit/tasks/test_tasks.py::test_task_retries::test_autoretry_backoff
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_autoretry_backoff_jitter
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_autoretry_for_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_override_autoretry_for_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_kwargs_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_override_retry_kwargs_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_backoff_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_override_retry_backoff_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_backoff_max_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_override_retry_backoff_max_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_backoff_jitter_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_override_backoff_jitter_from_base
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_retry_wrong_eta_when_not_enable_utc
> FAILED
> t/unit/tasks/test_tasks.py::test_task_retries::test_autoretry_class_based_task
> FAILED t/unit/tasks/test_tasks.py::test_apply_task::test_apply -
> billiard.ein...
> FAILED
> t/unit/utils/test_collections.py::test_ExceptionInfo::test_exception_info
> FAILED
> t/unit/worker/test_request.py::test_trace_task::test_execute_jail_failure
> FAILED t/unit/worker/test_request.py::test_Request::test_on_failure_Terminated
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_propagates_MemoryError
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_Ignore_acknowledges
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_Reject_rejects
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_Reject_rejects_with_requeue
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_WorkerLostError_rejects_with_requeue
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_WorkerLostError_redelivered_None
> FAILED t/unit/worker/test_request.py::test_Request::test_on_retry -
> Assertion...
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_success_BaseException
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_acks_late_reject_on_worker_lost_enabled
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure_task_cancelled
> FAILED
> t/unit/worker/test_request.py::test_Request::test_from_message_invalid_kwargs
> FAILED
> t/unit/worker/test_request.py::test_Request::test_on_failure__WorkerLostError
> FAILED
> t/unit/worker/test_request.py::test_create_request_class::test_on_success__SystemExit
> = 48 failed, 2296 passed, 28 skipped, 8 deselected, 3 xfailed, 456 warnings,
> 20 subtests passed in 71.87s (0:01:11) =
> E: pybuild pybuild:379: test: plugin distutils failed with: exit code=1: cd
> /<<PKGBUILDDIR>>/.pybuild/cpython3_3.10_celery/build; python3.10 -m pytest
> --ignore=t/unit/backends/test_base.py --ignore=t/unit/backends/test_rpc.py
> --ignore=t/unit/contrib/test_pytest.py
> --ignore=t/unit/concurrency/test_eventlet.py
> --ignore=t/unit/concurrency/test_prefork.py -k "not
> test_check_privileges[accept_content0] and not
> test_check_privileges[accept_content1] and not
> test_check_privileges[accept_content2] and not
> test_regression_worker_startup_info and not test_with_guid and not
> test_only_gid and not test_init_mongodb_dnspython2_pymongo3_seedlist" t/unit
> dh_auto_test: error: pybuild --test --test-pytest -i python{version} -p 3.10
> returned exit code 13
The full build log is available from:
http://qa-logs.debian.net/2022/09/17/celery_5.2.6-2_unstable.log
All bugs filed during this archive rebuild are listed at:
https://bugs.debian.org/cgi-bin/pkgreport.cgi?tag=ftbfs-20220917;users=lu...@debian.org
or:
https://udd.debian.org/bugs/?release=na&merged=ign&fnewerval=7&flastmodval=7&fusertag=only&fusertagtag=ftbfs-20220917&fusertaguser=lu...@debian.org&allbugs=1&cseverity=1&ctags=1&caffected=1#results
A list of current common problems and possible solutions is available at
http://wiki.debian.org/qa.debian.org/FTBFS . You're welcome to contribute!
If you reassign this bug to another package, please marking it as 'affects'-ing
this package. See https://www.debian.org/Bugs/server-control#affects
If you fail to reproduce this, please provide a build log and diff it with mine
so that we can identify if something relevant changed in the meantime.
