Diff of the two buildlogs: -- --- b1/build.log 2025-03-23 13:00:41.435611765 +0000 +++ b2/build.log 2025-03-23 13:39:40.146605674 +0000 @@ -1,6 +1,6 @@ I: pbuilder: network access will be disabled during build -I: Current time: Sun Mar 23 00:51:02 -12 2025 -I: pbuilder-time-stamp: 1742734262 +I: Current time: Sun Apr 26 09:23:59 +14 2026 +I: pbuilder-time-stamp: 1777145039 I: Building the build Environment I: extracting base tarball [/var/cache/pbuilder/trixie-reproducible-base.tgz] I: copying local configuration @@ -26,54 +26,86 @@ dpkg-source: info: applying 0002-Skip-a-couple-of-tests-TEMP.patch I: using fakeroot in build. I: Installing the build-deps -I: user script /srv/workspace/pbuilder/63960/tmp/hooks/D02_print_environment starting +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/D01_modify_environment starting +debug: Running on ionos16-i386. +I: Changing host+domainname to test build reproducibility +I: Adding a custom variable just for the fun of it... +I: Changing /bin/sh to bash +'/bin/sh' -> '/bin/bash' +lrwxrwxrwx 1 root root 9 Apr 25 19:25 /bin/sh -> /bin/bash +I: Setting pbuilder2's login shell to /bin/bash +I: Setting pbuilder2's GECOS to second user,second room,second work-phone,second home-phone,second other +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/D01_modify_environment finished +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/D02_print_environment starting I: set - BUILDDIR='/build/reproducible-path' - BUILDUSERGECOS='first user,first room,first work-phone,first home-phone,first other' - BUILDUSERNAME='pbuilder1' - BUILD_ARCH='i386' - DEBIAN_FRONTEND='noninteractive' - DEB_BUILD_OPTIONS='buildinfo=+all reproducible=+all parallel=11 ' - DISTRIBUTION='trixie' - HOME='/root' - HOST_ARCH='i386' + BASH=/bin/sh + BASHOPTS=checkwinsize:cmdhist:complete_fullquote:extquote:force_fignore:globasciiranges:globskipdots:hostcomplete:interactive_comments:patsub_replacement:progcomp:promptvars:sourcepath + BASH_ALIASES=() + BASH_ARGC=() + BASH_ARGV=() + BASH_CMDS=() + BASH_LINENO=([0]="12" [1]="0") + BASH_LOADABLES_PATH=/usr/local/lib/bash:/usr/lib/bash:/opt/local/lib/bash:/usr/pkg/lib/bash:/opt/pkg/lib/bash:. + BASH_SOURCE=([0]="/tmp/hooks/D02_print_environment" [1]="/tmp/hooks/D02_print_environment") + BASH_VERSINFO=([0]="5" [1]="2" [2]="37" [3]="1" [4]="release" [5]="i686-pc-linux-gnu") + BASH_VERSION='5.2.37(1)-release' + BUILDDIR=/build/reproducible-path + BUILDUSERGECOS='second user,second room,second work-phone,second home-phone,second other' + BUILDUSERNAME=pbuilder2 + BUILD_ARCH=i386 + DEBIAN_FRONTEND=noninteractive + DEB_BUILD_OPTIONS='buildinfo=+all reproducible=+all parallel=21 ' + DIRSTACK=() + DISTRIBUTION=trixie + EUID=0 + FUNCNAME=([0]="Echo" [1]="main") + GROUPS=() + HOME=/root + HOSTNAME=i-capture-the-hostname + HOSTTYPE=i686 + HOST_ARCH=i386 IFS=' ' - INVOCATION_ID='d0da4e98cb2a49b2acdb04130982b5a1' - LANG='C' - LANGUAGE='en_US:en' - LC_ALL='C' - LD_LIBRARY_PATH='/usr/lib/libeatmydata' - LD_PRELOAD='libeatmydata.so' - MAIL='/var/mail/root' - OPTIND='1' - PATH='/usr/sbin:/usr/bin:/sbin:/bin:/usr/games' - PBCURRENTCOMMANDLINEOPERATION='build' - PBUILDER_OPERATION='build' - PBUILDER_PKGDATADIR='/usr/share/pbuilder' - PBUILDER_PKGLIBDIR='/usr/lib/pbuilder' - PBUILDER_SYSCONFDIR='/etc' - PPID='63960' - PS1='# ' - PS2='> ' + INVOCATION_ID=f4c8882d48fd4b759295100703a67a3c + LANG=C + LANGUAGE=de_CH:de + LC_ALL=C + LD_LIBRARY_PATH=/usr/lib/libeatmydata + LD_PRELOAD=libeatmydata.so + MACHTYPE=i686-pc-linux-gnu + MAIL=/var/mail/root + OPTERR=1 + OPTIND=1 + OSTYPE=linux-gnu + PATH=/usr/sbin:/usr/bin:/sbin:/bin:/usr/games:/i/capture/the/path + PBCURRENTCOMMANDLINEOPERATION=build + PBUILDER_OPERATION=build + PBUILDER_PKGDATADIR=/usr/share/pbuilder + PBUILDER_PKGLIBDIR=/usr/lib/pbuilder + PBUILDER_SYSCONFDIR=/etc + PIPESTATUS=([0]="0") + POSIXLY_CORRECT=y + PPID=96818 PS4='+ ' - PWD='/' - SHELL='/bin/bash' - SHLVL='2' - SUDO_COMMAND='/usr/bin/timeout -k 18.1h 18h /usr/bin/ionice -c 3 /usr/bin/nice /usr/sbin/pbuilder --build --configfile /srv/reproducible-results/rbuild-debian/r-b-build.KpabOUSr/pbuilderrc_dur5 --distribution trixie --hookdir /etc/pbuilder/first-build-hooks --debbuildopts -b --basetgz /var/cache/pbuilder/trixie-reproducible-base.tgz --buildresult /srv/reproducible-results/rbuild-debian/r-b-build.KpabOUSr/b1 --logfile b1/build.log python-pypushflow_0.7.0-3.dsc' - SUDO_GID='112' - SUDO_UID='107' - SUDO_USER='jenkins' - TERM='unknown' - TZ='/usr/share/zoneinfo/Etc/GMT+12' - USER='root' - _='/usr/bin/systemd-run' - http_proxy='http://46.16.76.132:3128' + PWD=/ + SHELL=/bin/bash + SHELLOPTS=braceexpand:errexit:hashall:interactive-comments:posix + SHLVL=3 + SUDO_COMMAND='/usr/bin/timeout -k 24.1h 24h /usr/bin/ionice -c 3 /usr/bin/nice -n 11 /usr/bin/unshare --uts -- /usr/sbin/pbuilder --build --configfile /srv/reproducible-results/rbuild-debian/r-b-build.KpabOUSr/pbuilderrc_0Qq4 --distribution trixie --hookdir /etc/pbuilder/rebuild-hooks --debbuildopts -b --basetgz /var/cache/pbuilder/trixie-reproducible-base.tgz --buildresult /srv/reproducible-results/rbuild-debian/r-b-build.KpabOUSr/b2 --logfile b2/build.log python-pypushflow_0.7.0-3.dsc' + SUDO_GID=112 + SUDO_UID=107 + SUDO_USER=jenkins + TERM=unknown + TZ=/usr/share/zoneinfo/Etc/GMT-14 + UID=0 + USER=root + _='I: set' + http_proxy=http://213.165.73.152:3128 I: uname -a - Linux ionos12-i386 6.1.0-32-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.129-1 (2025-03-06) x86_64 GNU/Linux + Linux i-capture-the-hostname 6.1.0-32-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.129-1 (2025-03-06) x86_64 GNU/Linux I: ls -l /bin - lrwxrwxrwx 1 root root 7 Mar 4 11:20 /bin -> usr/bin -I: user script /srv/workspace/pbuilder/63960/tmp/hooks/D02_print_environment finished + lrwxrwxrwx 1 root root 7 Mar 4 2025 /bin -> usr/bin +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/D02_print_environment finished -> Attempting to satisfy build-dependencies -> Creating pbuilder-satisfydepends-dummy package Package: pbuilder-satisfydepends-dummy @@ -465,7 +497,7 @@ Get: 340 http://deb.debian.org/debian trixie/main i386 python3-qtpy all 2.4.2-9 [69.4 kB] Get: 341 http://deb.debian.org/debian trixie/main i386 python3-qtconsole all 5.6.1-4 [83.2 kB] Get: 342 http://deb.debian.org/debian trixie/main i386 python3-silx i386 2.2.1+dfsg-2 [2442 kB] -Fetched 292 MB in 6s (52.1 MB/s) +Fetched 292 MB in 10s (28.7 MB/s) Preconfiguring packages ... Selecting previously unselected package libtext-charwidth-perl:i386. (Reading database ... (Reading database ... 5% (Reading database ... 10% (Reading database ... 15% (Reading database ... 20% (Reading database ... 25% (Reading database ... 30% (Reading database ... 35% (Reading database ... 40% (Reading database ... 45% (Reading database ... 50% (Reading database ... 55% (Reading database ... 60% (Reading database ... 65% (Reading database ... 70% (Reading database ... 75% (Reading database ... 80% (Reading database ... 85% (Reading database ... 90% (Reading database ... 95% (Reading database ... 100% (Reading database ... 19772 files and directories currently installed.) @@ -1569,8 +1601,8 @@ Setting up tzdata (2025a-2) ... Current default time zone: 'Etc/UTC' -Local time is now: Sun Mar 23 12:52:01 UTC 2025. -Universal Time is now: Sun Mar 23 12:52:01 UTC 2025. +Local time is now: Sat Apr 25 19:29:35 UTC 2026. +Universal Time is now: Sat Apr 25 19:29:35 UTC 2026. Run 'dpkg-reconfigure tzdata' if you wish to change it. Setting up libxcb-present0:i386 (1.17.0-2+b1) ... @@ -1881,7 +1913,11 @@ fakeroot is already the newest version (1.37.1-1). 0 upgraded, 0 newly installed, 0 to remove and 0 not upgraded. I: Building the package -I: Running cd /build/reproducible-path/python-pypushflow-0.7.0/ && env PATH="/usr/sbin:/usr/bin:/sbin:/bin:/usr/games" HOME="/nonexistent/first-build" dpkg-buildpackage -us -uc -b && env PATH="/usr/sbin:/usr/bin:/sbin:/bin:/usr/games" HOME="/nonexistent/first-build" dpkg-genchanges -S > ../python-pypushflow_0.7.0-3_source.changes +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/A99_set_merged_usr starting +Not re-configuring usrmerge for trixie +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/A99_set_merged_usr finished +hostname: Name or service not known +I: Running cd /build/reproducible-path/python-pypushflow-0.7.0/ && env PATH="/usr/sbin:/usr/bin:/sbin:/bin:/usr/games:/i/capture/the/path" HOME="/nonexistent/second-build" dpkg-buildpackage -us -uc -b && env PATH="/usr/sbin:/usr/bin:/sbin:/bin:/usr/games:/i/capture/the/path" HOME="/nonexistent/second-build" dpkg-genchanges -S > ../python-pypushflow_0.7.0-3_source.changes dpkg-buildpackage: info: source package python-pypushflow dpkg-buildpackage: info: source version 0.7.0-3 dpkg-buildpackage: info: source distribution unstable @@ -1906,175 +1942,175 @@ running build running build_py creating build/lib/pypushflow -copying src/pypushflow/PythonActor.py -> build/lib/pypushflow -copying src/pypushflow/StartActor.py -> build/lib/pypushflow copying src/pypushflow/RequestStatus.py -> build/lib/pypushflow copying src/pypushflow/AbstractActor.py -> build/lib/pypushflow -copying src/pypushflow/AsyncExecute.py -> build/lib/pypushflow -copying src/pypushflow/ThreadCounter.py -> build/lib/pypushflow -copying src/pypushflow/ActorInterface.py -> build/lib/pypushflow -copying src/pypushflow/__init__.py -> build/lib/pypushflow -copying src/pypushflow/JoinActor.py -> build/lib/pypushflow -copying src/pypushflow/logutils.py -> build/lib/pypushflow -copying src/pypushflow/Workflow.py -> build/lib/pypushflow copying src/pypushflow/stop_workflows.py -> build/lib/pypushflow -copying src/pypushflow/RouterActor.py -> build/lib/pypushflow +copying src/pypushflow/StartActor.py -> build/lib/pypushflow +copying src/pypushflow/ThreadCounter.py -> build/lib/pypushflow copying src/pypushflow/Submodel.py -> build/lib/pypushflow +copying src/pypushflow/AsyncExecute.py -> build/lib/pypushflow +copying src/pypushflow/Workflow.py -> build/lib/pypushflow copying src/pypushflow/ErrorHandler.py -> build/lib/pypushflow -copying src/pypushflow/ThreadCountingActor.py -> build/lib/pypushflow +copying src/pypushflow/PythonActor.py -> build/lib/pypushflow +copying src/pypushflow/__init__.py -> build/lib/pypushflow copying src/pypushflow/ForkActor.py -> build/lib/pypushflow copying src/pypushflow/StopActor.py -> build/lib/pypushflow +copying src/pypushflow/RouterActor.py -> build/lib/pypushflow +copying src/pypushflow/logutils.py -> build/lib/pypushflow +copying src/pypushflow/ActorInterface.py -> build/lib/pypushflow +copying src/pypushflow/JoinActor.py -> build/lib/pypushflow +copying src/pypushflow/ThreadCountingActor.py -> build/lib/pypushflow +creating build/lib/pypushflow/persistence +copying src/pypushflow/persistence/interface.py -> build/lib/pypushflow/persistence +copying src/pypushflow/persistence/mongo.py -> build/lib/pypushflow/persistence +copying src/pypushflow/persistence/dummy.py -> build/lib/pypushflow/persistence +copying src/pypushflow/persistence/pymongo.py -> build/lib/pypushflow/persistence +copying src/pypushflow/persistence/__init__.py -> build/lib/pypushflow/persistence +copying src/pypushflow/persistence/mongita.py -> build/lib/pypushflow/persistence +copying src/pypushflow/persistence/besdb.py -> build/lib/pypushflow/persistence creating build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/factory.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/non_daemonic.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/thread.py -> build/lib/pypushflow/concurrent copying src/pypushflow/concurrent/ndmultiprocessing.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/gevent.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/__init__.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/exceptions.py -> build/lib/pypushflow/concurrent copying src/pypushflow/concurrent/process.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/thread.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/exceptions.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/ndprocess.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/non_daemonic.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/scaling.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/__init__.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/multiprocessing.py -> build/lib/pypushflow/concurrent copying src/pypushflow/concurrent/billiard.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/gevent.py -> build/lib/pypushflow/concurrent +copying src/pypushflow/concurrent/factory.py -> build/lib/pypushflow/concurrent copying src/pypushflow/concurrent/base.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/multiprocessing.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/scaling.py -> build/lib/pypushflow/concurrent -copying src/pypushflow/concurrent/ndprocess.py -> build/lib/pypushflow/concurrent creating build/lib/pypushflow/tests +copying src/pypushflow/tests/workflowTestCase.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/test_workflow3.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/conftest.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/test_workflow1.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_workflow6.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_persistency.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/workflowTestCase.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/test_stop_workflow.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/__init__.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_threadcounteractor.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_workflow5.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/test_workflow1.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/test_actors.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_workflow4.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/__init__.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/test_workflow10.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/conftest.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/test_actors.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/test_stop_workflow.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_threadcounter.py -> build/lib/pypushflow/tests +copying src/pypushflow/tests/test_workflow10.py -> build/lib/pypushflow/tests copying src/pypushflow/tests/test_workflow2.py -> build/lib/pypushflow/tests -copying src/pypushflow/tests/test_workflow3.py -> build/lib/pypushflow/tests -creating build/lib/pypushflow/persistence -copying src/pypushflow/persistence/dummy.py -> build/lib/pypushflow/persistence -copying src/pypushflow/persistence/interface.py -> build/lib/pypushflow/persistence -copying src/pypushflow/persistence/besdb.py -> build/lib/pypushflow/persistence -copying src/pypushflow/persistence/mongo.py -> build/lib/pypushflow/persistence -copying src/pypushflow/persistence/mongita.py -> build/lib/pypushflow/persistence -copying src/pypushflow/persistence/__init__.py -> build/lib/pypushflow/persistence -copying src/pypushflow/persistence/pymongo.py -> build/lib/pypushflow/persistence creating build/lib/pypushflow/concurrent/interrupt -copying src/pypushflow/concurrent/interrupt/gevent.py -> build/lib/pypushflow/concurrent/interrupt -copying src/pypushflow/concurrent/interrupt/__init__.py -> build/lib/pypushflow/concurrent/interrupt copying src/pypushflow/concurrent/interrupt/process.py -> build/lib/pypushflow/concurrent/interrupt +copying src/pypushflow/concurrent/interrupt/__init__.py -> build/lib/pypushflow/concurrent/interrupt +copying src/pypushflow/concurrent/interrupt/gevent.py -> build/lib/pypushflow/concurrent/interrupt +creating build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonLongExecutionTest.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorAdd2.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorSleep.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorAddAndCheck.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonErrorHandlerTest.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorAddWithoutSleep.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActor2.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorInterrupt.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorTest.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/__init__.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorAdd.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActorCheck.py -> build/lib/pypushflow/tests/tasks +copying src/pypushflow/tests/tasks/pythonActor1.py -> build/lib/pypushflow/tests/tasks creating build/lib/pypushflow/tests/concurrent copying src/pypushflow/tests/concurrent/filter_combinations.py -> build/lib/pypushflow/tests/concurrent +copying src/pypushflow/tests/concurrent/__init__.py -> build/lib/pypushflow/tests/concurrent +copying src/pypushflow/tests/concurrent/utils.py -> build/lib/pypushflow/tests/concurrent copying src/pypushflow/tests/concurrent/check_daemonic.py -> build/lib/pypushflow/tests/concurrent -copying src/pypushflow/tests/concurrent/test_apply_async.py -> build/lib/pypushflow/tests/concurrent copying src/pypushflow/tests/concurrent/test_nesting.py -> build/lib/pypushflow/tests/concurrent +copying src/pypushflow/tests/concurrent/test_apply_async.py -> build/lib/pypushflow/tests/concurrent copying src/pypushflow/tests/concurrent/test_interrupt.py -> build/lib/pypushflow/tests/concurrent -copying src/pypushflow/tests/concurrent/__init__.py -> build/lib/pypushflow/tests/concurrent -copying src/pypushflow/tests/concurrent/utils.py -> build/lib/pypushflow/tests/concurrent -creating build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActor2.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorAdd.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActor1.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorSleep.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorCheck.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorAdd2.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonLongExecutionTest.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/__init__.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorTest.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorInterrupt.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonErrorHandlerTest.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorAddWithoutSleep.py -> build/lib/pypushflow/tests/tasks -copying src/pypushflow/tests/tasks/pythonActorAddAndCheck.py -> build/lib/pypushflow/tests/tasks installing to build/bdist.linux-i686/wheel running install running install_lib creating build/bdist.linux-i686/wheel creating build/bdist.linux-i686/wheel/pypushflow +copying build/lib/pypushflow/RequestStatus.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/AbstractActor.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/stop_workflows.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/StartActor.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/ThreadCounter.py -> build/bdist.linux-i686/wheel/./pypushflow +creating build/bdist.linux-i686/wheel/pypushflow/persistence +copying build/lib/pypushflow/persistence/interface.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/persistence/mongo.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/persistence/dummy.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/persistence/pymongo.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/persistence/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/persistence/mongita.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/persistence/besdb.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence +copying build/lib/pypushflow/Submodel.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/AsyncExecute.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/Workflow.py -> build/bdist.linux-i686/wheel/./pypushflow creating build/bdist.linux-i686/wheel/pypushflow/concurrent -copying build/lib/pypushflow/concurrent/factory.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/non_daemonic.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/thread.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent copying build/lib/pypushflow/concurrent/ndmultiprocessing.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/gevent.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -creating build/bdist.linux-i686/wheel/pypushflow/concurrent/interrupt -copying build/lib/pypushflow/concurrent/interrupt/gevent.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent/interrupt -copying build/lib/pypushflow/concurrent/interrupt/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent/interrupt -copying build/lib/pypushflow/concurrent/interrupt/process.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent/interrupt -copying build/lib/pypushflow/concurrent/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/exceptions.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent copying build/lib/pypushflow/concurrent/process.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/thread.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/exceptions.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/ndprocess.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/non_daemonic.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/scaling.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/multiprocessing.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent copying build/lib/pypushflow/concurrent/billiard.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +creating build/bdist.linux-i686/wheel/pypushflow/concurrent/interrupt +copying build/lib/pypushflow/concurrent/interrupt/process.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent/interrupt +copying build/lib/pypushflow/concurrent/interrupt/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent/interrupt +copying build/lib/pypushflow/concurrent/interrupt/gevent.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent/interrupt +copying build/lib/pypushflow/concurrent/gevent.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/concurrent/factory.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent copying build/lib/pypushflow/concurrent/base.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/multiprocessing.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/scaling.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent -copying build/lib/pypushflow/concurrent/ndprocess.py -> build/bdist.linux-i686/wheel/./pypushflow/concurrent +copying build/lib/pypushflow/ErrorHandler.py -> build/bdist.linux-i686/wheel/./pypushflow copying build/lib/pypushflow/PythonActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/StartActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/RequestStatus.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/ForkActor.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/StopActor.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/RouterActor.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/logutils.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/ActorInterface.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/JoinActor.py -> build/bdist.linux-i686/wheel/./pypushflow +copying build/lib/pypushflow/ThreadCountingActor.py -> build/bdist.linux-i686/wheel/./pypushflow creating build/bdist.linux-i686/wheel/pypushflow/tests -copying build/lib/pypushflow/tests/test_workflow6.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/test_persistency.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/workflowTestCase.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +creating build/bdist.linux-i686/wheel/pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonLongExecutionTest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorAdd2.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorSleep.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorAddAndCheck.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonErrorHandlerTest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorAddWithoutSleep.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActor2.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorInterrupt.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorTest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorAdd.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActorCheck.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/tasks/pythonActor1.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks +copying build/lib/pypushflow/tests/test_workflow3.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/conftest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/test_workflow1.py -> build/bdist.linux-i686/wheel/./pypushflow/tests creating build/bdist.linux-i686/wheel/pypushflow/tests/concurrent copying build/lib/pypushflow/tests/concurrent/filter_combinations.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent +copying build/lib/pypushflow/tests/concurrent/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent +copying build/lib/pypushflow/tests/concurrent/utils.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent copying build/lib/pypushflow/tests/concurrent/check_daemonic.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent -copying build/lib/pypushflow/tests/concurrent/test_apply_async.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent copying build/lib/pypushflow/tests/concurrent/test_nesting.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent +copying build/lib/pypushflow/tests/concurrent/test_apply_async.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent copying build/lib/pypushflow/tests/concurrent/test_interrupt.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent -copying build/lib/pypushflow/tests/concurrent/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent -copying build/lib/pypushflow/tests/concurrent/utils.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/concurrent -copying build/lib/pypushflow/tests/workflowTestCase.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/test_stop_workflow.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/test_workflow6.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/test_persistency.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/tests copying build/lib/pypushflow/tests/test_threadcounteractor.py -> build/bdist.linux-i686/wheel/./pypushflow/tests copying build/lib/pypushflow/tests/test_workflow5.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/test_workflow1.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/test_actors.py -> build/bdist.linux-i686/wheel/./pypushflow/tests copying build/lib/pypushflow/tests/test_workflow4.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/test_workflow10.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/tests/conftest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/test_actors.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/test_stop_workflow.py -> build/bdist.linux-i686/wheel/./pypushflow/tests copying build/lib/pypushflow/tests/test_threadcounter.py -> build/bdist.linux-i686/wheel/./pypushflow/tests +copying build/lib/pypushflow/tests/test_workflow10.py -> build/bdist.linux-i686/wheel/./pypushflow/tests copying build/lib/pypushflow/tests/test_workflow2.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -creating build/bdist.linux-i686/wheel/pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActor2.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorAdd.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActor1.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorSleep.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorCheck.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorAdd2.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonLongExecutionTest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorTest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorInterrupt.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonErrorHandlerTest.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorAddWithoutSleep.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/tasks/pythonActorAddAndCheck.py -> build/bdist.linux-i686/wheel/./pypushflow/tests/tasks -copying build/lib/pypushflow/tests/test_workflow3.py -> build/bdist.linux-i686/wheel/./pypushflow/tests -copying build/lib/pypushflow/AbstractActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/AsyncExecute.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/ThreadCounter.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/ActorInterface.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/JoinActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/logutils.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/Workflow.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/stop_workflows.py -> build/bdist.linux-i686/wheel/./pypushflow -creating build/bdist.linux-i686/wheel/pypushflow/persistence -copying build/lib/pypushflow/persistence/dummy.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/persistence/interface.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/persistence/besdb.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/persistence/mongo.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/persistence/mongita.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/persistence/__init__.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/persistence/pymongo.py -> build/bdist.linux-i686/wheel/./pypushflow/persistence -copying build/lib/pypushflow/RouterActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/Submodel.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/ErrorHandler.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/ThreadCountingActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/ForkActor.py -> build/bdist.linux-i686/wheel/./pypushflow -copying build/lib/pypushflow/StopActor.py -> build/bdist.linux-i686/wheel/./pypushflow running install_egg_info running egg_info creating src/pypushflow.egg-info @@ -2089,7 +2125,7 @@ Copying src/pypushflow.egg-info to build/bdist.linux-i686/wheel/./pypushflow-0.7.0.egg-info running install_scripts creating build/bdist.linux-i686/wheel/pypushflow-0.7.0.dist-info/WHEEL -creating '/build/reproducible-path/python-pypushflow-0.7.0/.pybuild/cpython3_3.13/.tmp-53g5jf9v/pypushflow-0.7.0-py3-none-any.whl' and adding 'build/bdist.linux-i686/wheel' to it +creating '/build/reproducible-path/python-pypushflow-0.7.0/.pybuild/cpython3_3.13/.tmp-234jwk9s/pypushflow-0.7.0-py3-none-any.whl' and adding 'build/bdist.linux-i686/wheel' to it adding 'pypushflow/AbstractActor.py' adding 'pypushflow/ActorInterface.py' adding 'pypushflow/AsyncExecute.py' @@ -2188,10 +2224,10 @@ pypushflow/tests/concurrent/test_interrupt.py ssss................ssssss [ 7%] ss [ 7%] pypushflow/tests/concurrent/test_nesting.py .....ss.....ss.....ss.....ss [ 10%] -.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.. [ 16%] +.....ss.....ss.....ss...FFss.....ss..F..ss.FFFFss...FFss.....ss.....ss.. [ 16%] ...ss.....ss.....ss.....ss.....ss.....ssssssssssssssssssssssssssssssssss [ 22%] -ssssssssssssssssssssssss.....ss.....ss.....ss.....ss.....ss.....ss.....s [ 29%] -s.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss. [ 35%] +ssssssssssssssssssssssss.....ss.....ss.....ss.....ss.....ss.....ss..F.Fs [ 29%] +sF.FF.ss.....ss.....ss...FFss.....ss.....ss.....ss.....ss.....ss.....ss. [ 35%] ....ss.....ss.....ssssssssssssssssssssssssssssssssssssssssssssssssssssss [ 42%] ssss....................ssssssss....................ssssssss [ 47%] pypushflow/tests/test_actors.py ..... [ 48%] @@ -2210,10 +2246,10 @@ .............ssssssss [ 55%] tests/concurrent/test_interrupt.py ssss................ssssssss [ 57%] tests/concurrent/test_nesting.py .....ss.....ss.....ss.....ss.....ss.... [ 61%] -.ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....s [ 67%] +.ss.....ss...F.ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....s [ 67%] s.....ss.....ss.....ss.....sssssssssssssssssssssssssssssssssssssssssssss [ 73%] -sssssssssssss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss... [ 80%] -..ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss.....ss..... [ 86%] +sssssssssssss..F..ss..F..ss.....ss.....ss.....ss.....ss.....ss.....ss... [ 80%] +..ss.....ss....Fss...F.ss.....ss.....ss.....ss.....ss.....ss.....ss..... [ 86%] ss.....ssssssssssssssssssssssssssssssssssssssssssssssssssssssssss....... [ 93%] .............ssssssss....................ssssssss [ 97%] tests/test_actors.py ..... [ 98%] @@ -2229,54 +2265,954 @@ tests/test_workflow5.py . [ 99%] tests/test_workflow6.py . [100%] +=================================== FAILURES =================================== +________________ test_callback[True-process-forkserver-mppool] _________________ + +task_name = 'mppool', context = 'forkserver', pool_type = 'process' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +_______________ test_callback[True-process-forkserver-mpprocess] _______________ + +task_name = 'mpprocess', context = 'forkserver', pool_type = 'process' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +__________________ test_callback[True-ndprocess-fork-cfpool] ___________________ + +task_name = 'cfpool', context = 'fork', pool_type = 'ndprocess', scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[True-ndprocess-spawn-subprocess] ________________ + +task_name = 'subprocess', context = 'spawn', pool_type = 'ndprocess' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +__________________ test_callback[True-ndprocess-spawn-cfpool] __________________ + +task_name = 'cfpool', context = 'spawn', pool_type = 'ndprocess', scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +__________________ test_callback[True-ndprocess-spawn-mppool] __________________ + +task_name = 'mppool', context = 'spawn', pool_type = 'ndprocess', scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[True-ndprocess-spawn-mpprocess] _________________ + +task_name = 'mpprocess', context = 'spawn', pool_type = 'ndprocess' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +_______________ test_callback[True-ndprocess-forkserver-mppool] ________________ + +task_name = 'mppool', context = 'forkserver', pool_type = 'ndprocess' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +______________ test_callback[True-ndprocess-forkserver-mpprocess] ______________ + +task_name = 'mpprocess', context = 'forkserver', pool_type = 'ndprocess' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +__________________ test_callback[False-process-spawn-cfpool] ___________________ + +task_name = 'cfpool', context = 'spawn', pool_type = 'process', scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +_________________ test_callback[False-process-spawn-mpprocess] _________________ + +task_name = 'mpprocess', context = 'spawn', pool_type = 'process' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[False-process-forkserver-simple] ________________ + +task_name = 'simple', context = 'forkserver', pool_type = 'process' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[False-process-forkserver-cfpool] ________________ + +task_name = 'cfpool', context = 'forkserver', pool_type = 'process' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[False-process-forkserver-mppool] ________________ + +task_name = 'mppool', context = 'forkserver', pool_type = 'process' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +_________________ test_callback[False-ndprocess-spawn-mppool] __________________ + +task_name = 'mppool', context = 'spawn', pool_type = 'ndprocess' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[False-ndprocess-spawn-mpprocess] ________________ + +task_name = 'mpprocess', context = 'spawn', pool_type = 'ndprocess' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +pypushflow/tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +pypushflow/tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +pypushflow/tests/concurrent/utils.py:88: AssertionError +________________ test_callback[True-process-forkserver-mppool] _________________ + +task_name = 'mppool', context = 'forkserver', pool_type = 'process' +scaling = True + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +tests/concurrent/utils.py:88: AssertionError +___________________ test_callback[False-thread-None-cfpool] ____________________ + +task_name = 'cfpool', context = None, pool_type = 'thread', scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +tests/concurrent/utils.py:88: AssertionError +___________________ test_callback[False-thread-fork-cfpool] ____________________ + +task_name = 'cfpool', context = 'fork', pool_type = 'thread', scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +tests/concurrent/utils.py:88: AssertionError +________________ test_callback[False-ndprocess-spawn-mpprocess] ________________ + +task_name = 'mpprocess', context = 'spawn', pool_type = 'ndprocess' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +tests/concurrent/utils.py:88: AssertionError +_______________ test_callback[False-ndprocess-forkserver-mppool] _______________ + +task_name = 'mppool', context = 'forkserver', pool_type = 'ndprocess' +scaling = False + + @pytest.mark.parametrize("task_name", list(utils.SUCCESS)) + @pytest.mark.parametrize("context", utils.CONTEXTS) + @pytest.mark.parametrize("pool_type", utils.POOLS) + @pytest.mark.parametrize("scaling", [True, False]) + def test_callback(task_name, context, pool_type, scaling): + with utils.pool_context(scaling, pool_type, context=context) as pool: + with filter_combinations.filter_callback(pool_type, task_name, context): +> utils.assert_callback(pool, task_name) + +tests/concurrent/test_nesting.py:13: +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ +tests/concurrent/utils.py:51: in assert_callback + value, exception = _submit_with_cb(pool, fn) +_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ + +pool = +fn = + + def _submit_with_cb(pool, fn) -> Tuple[Any, Optional[Exception]]: + value = None + exception = None + ev = Event() + + def cb(result): + nonlocal value + value = result + ev.set() + + def ecb(result): + nonlocal exception + exception = result + ev.set() + + pool.apply_async(fn, callback=cb, error_callback=ecb) +> assert ev.wait(timeout=TIMEOUT) +E AssertionError + +tests/concurrent/utils.py:88: AssertionError =============================== warnings summary =============================== .pybuild/cpython3_3.13/build/pypushflow/tests/concurrent/test_interrupt.py: 12 warnings -.pybuild/cpython3_3.13/build/pypushflow/tests/concurrent/test_nesting.py: 224 warnings +.pybuild/cpython3_3.13/build/pypushflow/tests/concurrent/test_nesting.py: 400 warnings .pybuild/cpython3_3.13/build/pypushflow/tests/test_stop_workflow.py: 24 warnings .pybuild/cpython3_3.13/build/tests/concurrent/test_interrupt.py: 12 warnings -.pybuild/cpython3_3.13/build/tests/concurrent/test_nesting.py: 224 warnings +.pybuild/cpython3_3.13/build/tests/concurrent/test_nesting.py: 400 warnings .pybuild/cpython3_3.13/build/tests/test_stop_workflow.py: 24 warnings - /usr/lib/python3.13/multiprocessing/popen_fork.py:67: DeprecationWarning: This process (pid=10230) is multi-threaded, use of fork() may lead to deadlocks in the child. + /usr/lib/python3.13/multiprocessing/popen_fork.py:67: DeprecationWarning: This process (pid=116824) is multi-threaded, use of fork() may lead to deadlocks in the child. self.pid = os.fork() -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html -========== 638 passed, 480 skipped, 520 warnings in 437.10s (0:07:17) ========== - create-stamp debian/debhelper-build-stamp - dh_testroot -O--buildsystem=pybuild - dh_prep -O--buildsystem=pybuild - dh_auto_install --destdir=debian/python3-pypushflow/ -O--buildsystem=pybuild -I: pybuild plugin_pyproject:178: Copying package built for python3.13 to destdir - dh_installdocs -O--buildsystem=pybuild - dh_installchangelogs -O--buildsystem=pybuild - dh_python3 -O--buildsystem=pybuild -I: dh_python3 pydist:339: Ignoring complex environment marker: mongomock<4.2.0; python_version < "3.8" and extra == "test" -I: dh_python3 pydist:339: Ignoring complex environment marker: mongomock<4.2.0; python_version < "3.8" and extra == "dev" -I: dh_python3 pydist:339: Ignoring complex environment marker: mongomock<4.2.0; python_version < "3.8" and extra == "doc" - dh_installsystemduser -O--buildsystem=pybuild - dh_perl -O--buildsystem=pybuild - dh_link -O--buildsystem=pybuild - dh_strip_nondeterminism -O--buildsystem=pybuild - dh_compress -O--buildsystem=pybuild - dh_fixperms -O--buildsystem=pybuild - dh_missing -O--buildsystem=pybuild - dh_installdeb -O--buildsystem=pybuild - dh_gencontrol -O--buildsystem=pybuild - dh_md5sums -O--buildsystem=pybuild - dh_builddeb -O--buildsystem=pybuild -dpkg-deb: building package 'python3-pypushflow' in '../python3-pypushflow_0.7.0-3_all.deb'. - dpkg-genbuildinfo --build=binary -O../python-pypushflow_0.7.0-3_i386.buildinfo - dpkg-genchanges --build=binary -O../python-pypushflow_0.7.0-3_i386.changes -dpkg-genchanges: info: binary-only upload (no source code included) - dpkg-source --after-build . -dpkg-buildpackage: info: binary-only upload (no source included) -dpkg-genchanges: info: not including original source code in upload +=========================== short test summary info ============================ +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-process-forkserver-mppool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-process-forkserver-mpprocess] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-fork-cfpool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-spawn-subprocess] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-spawn-cfpool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-spawn-mppool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-spawn-mpprocess] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-forkserver-mppool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[True-ndprocess-forkserver-mpprocess] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-process-spawn-cfpool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-process-spawn-mpprocess] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-process-forkserver-simple] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-process-forkserver-cfpool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-process-forkserver-mppool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-ndprocess-spawn-mppool] +FAILED pypushflow/tests/concurrent/test_nesting.py::test_callback[False-ndprocess-spawn-mpprocess] +FAILED tests/concurrent/test_nesting.py::test_callback[True-process-forkserver-mppool] +FAILED tests/concurrent/test_nesting.py::test_callback[False-thread-None-cfpool] +FAILED tests/concurrent/test_nesting.py::test_callback[False-thread-fork-cfpool] +FAILED tests/concurrent/test_nesting.py::test_callback[False-ndprocess-spawn-mpprocess] +FAILED tests/concurrent/test_nesting.py::test_callback[False-ndprocess-forkserver-mppool] +==== 21 failed, 617 passed, 480 skipped, 872 warnings in 1533.76s (0:25:33) ==== +E: pybuild pybuild:389: test: plugin pyproject failed with: exit code=1: cd /build/reproducible-path/python-pypushflow-0.7.0/.pybuild/cpython3_3.13/build; python3.13 -m pytest +dh_auto_test: error: pybuild --test --test-pytest -i python{version} -p 3.13 returned exit code 13 +make: *** [debian/rules:4: binary] Error 25 +dpkg-buildpackage: error: debian/rules binary subprocess returned exit status 2 I: copying local configuration +E: Failed autobuilding of package +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/C01_cleanup starting +debug output: disk usage on i-capture-the-hostname at Sat Apr 25 20:01:35 UTC 2026 +Filesystem Size Used Avail Use% Mounted on +tmpfs 3.9G 0 3.9G 0% /dev/shm + +I: user script /srv/workspace/pbuilder/96818/tmp/hooks/C01_cleanup finished I: unmounting dev/ptmx filesystem I: unmounting dev/pts filesystem I: unmounting dev/shm filesystem I: unmounting proc filesystem I: unmounting sys filesystem I: cleaning the build env -I: removing directory /srv/workspace/pbuilder/63960 and its subdirectories -I: Current time: Sun Mar 23 01:00:40 -12 2025 -I: pbuilder-time-stamp: 1742734840 +I: removing directory /srv/workspace/pbuilder/96818 and its subdirectories