Running as unit: rb-build-amd64_32-58499.service; invocation ID: a6f7014193d04ebe85b9b2f53991c212 ==================================================================================== Fri Sep 19 13:14:53 UTC 2025 - running /srv/jenkins/bin/reproducible_build.sh (for job reproducible_builder_amd64_32) on jenkins, called using "ionos5-amd64 ionos11-amd64" as arguments. Fri Sep 19 13:14:53 UTC 2025 - actually running "reproducible_build.sh" (md5sum cc591790ab2c8e13f5e554202b95c89c) as "/tmp/jenkins-script-eb9jKrxV" $ git clone https://salsa.debian.org/qa/jenkins.debian.net.git ; more CONTRIBUTING Fri Sep 19 13:14:53 UTC 2025 - checking /var/lib/jenkins/offline_nodes if ionos5-amd64.debian.net is marked as down. Fri Sep 19 13:14:53 UTC 2025 - checking via ssh if ionos5-amd64.debian.net is up. removed '/tmp/read-only-fs-test-eIRudK' Fri Sep 19 13:14:54 UTC 2025 - checking /var/lib/jenkins/offline_nodes if ionos11-amd64.debian.net is marked as down. Fri Sep 19 13:14:54 UTC 2025 - checking via ssh if ionos11-amd64.debian.net is up. removed '/tmp/read-only-fs-test-YBD5Cc' ok, let's check if python-aiostream is building anywhere yet… ok, python-aiostream is not building anywhere… UPDATE 1 ============================================================================= Initialising reproducibly build of python-aiostream in unstable on amd64 on jenkins now. 1st build will be done on ionos5-amd64.debian.net. 2nd build will be done on ionos11-amd64.debian.net. ============================================================================= Fri Sep 19 13:15:06 UTC 2025 I: starting to build python-aiostream/unstable/amd64 on jenkins on '2025-09-19 13:14' Fri Sep 19 13:15:06 UTC 2025 I: The jenkins build log is/was available at https://jenkins.debian.net/userContent/reproducible/debian/build_service/amd64_32/58499/console.log 1758287706 amd64 unstable python-aiostream Fri Sep 19 13:15:06 UTC 2025 I: Downloading source for unstable/python-aiostream=0.5.2-2 --2025-09-19 13:15:06-- http://deb.debian.org/debian/pool/main/p/python-aiostream/python-aiostream_0.5.2-2.dsc Connecting to 46.16.76.132:3128... connected. Proxy request sent, awaiting response... 200 OK Length: 2210 (2.2K) [text/prs.lines.tag] Saving to: ‘python-aiostream_0.5.2-2.dsc’ 0K .. 100% 213M=0s 2025-09-19 13:15:06 (213 MB/s) - ‘python-aiostream_0.5.2-2.dsc’ saved [2210/2210] --2025-09-19 13:15:06-- http://deb.debian.org/debian/pool/main/p/python-aiostream/python-aiostream_0.5.2-2.dsc Connecting to 46.16.76.132:3128... connected. Proxy request sent, awaiting response... 200 OK Length: 2210 (2.2K) [text/prs.lines.tag] Saving to: ‘python-aiostream_0.5.2-2.dsc’ 0K .. 100% 213M=0s 2025-09-19 13:15:06 (213 MB/s) - ‘python-aiostream_0.5.2-2.dsc’ saved [2210/2210] Fri Sep 19 13:15:06 UTC 2025 I: python-aiostream_0.5.2-2.dsc -----BEGIN PGP SIGNED MESSAGE----- Hash: SHA512 Format: 3.0 (quilt) Source: python-aiostream Binary: python3-aiostream Architecture: all Version: 0.5.2-2 Maintainer: Debian Python Team Uploaders: nicoo , Homepage: https://github.com/vxgmichel/aiostream Standards-Version: 4.6.2 Vcs-Browser: https://salsa.debian.org/python-team/packages/python-aiostream Vcs-Git: https://salsa.debian.org/python-team/packages/python-aiostream.git Build-Depends: debhelper-compat (= 13), dh-sequence-python3, python3-all, python3-pytest , python3-pytest-asyncio , python3-pytest-cov , python3-pytest-runner , python3-typing-extensions Package-List: python3-aiostream deb python optional arch=all Checksums-Sha1: 8d570dd7a54877f31bbb3ea1bda9b8d9ba0da884 37368 python-aiostream_0.5.2.orig.tar.xz 708ed136726630ac1378d1e291f6e29d1679fc86 2168 python-aiostream_0.5.2-2.debian.tar.xz Checksums-Sha256: 92d0bbacfe149457ba7cbffb0532d8a822d2e921a5288098224b56fdaeb93e5e 37368 python-aiostream_0.5.2.orig.tar.xz 7c05afb8cfb91d581156e7aa7a88136acb27ffec74a01efdba919e27379e63af 2168 python-aiostream_0.5.2-2.debian.tar.xz Files: 335ba148f4b2ad9d8a84b2a36b71b5f4 37368 python-aiostream_0.5.2.orig.tar.xz 61d3555f73480b66a4e9a771f171b264 2168 python-aiostream_0.5.2-2.debian.tar.xz -----BEGIN PGP SIGNATURE----- iQJFBAEBCgAvFiEEj23hBDd/OxHnQXSHMfMURUShdBoFAmbWETsRHHRjaGV0QGRl Ymlhbi5vcmcACgkQMfMURUShdBr+cg//edhktD+JduI3HYWuIuhpBLcYWtpY9alK /SHG3pCBjIumsSNDrrNAMSXOcFHizPsYXH6xtctIJiWro+azru8YB6ORuKLQ0tBB bJl57D/fuRNg6tubWAEVsFnOt3EErPCWZaTiOwPF8r8+AmSH8rzTGgy5J+GcdIJm 6bcBrMOnPE7ICuh/jOBO57V1iSfdoOZqgaBbvAOEtTmp0evs0rKpWQBHBx7iHHls ko+CYsy1Tjd+KOfVYNWTNMmn09m/UWHVhaTrR3Wq8jv+yCgsepvrkIQCGLN2Z85P c4rxtn6k4+YZ3hT9e35oqBKvLpHLrKwIlfaQCjGMRAOThZngF0ts8G4QRLGFMJT7 4LTDMjY8xGD25n7/Ko9YEJCzuyrikgXvoIygYMlw7A1TsVb1GnOr70hgverP/geJ diXHUq6YJfm4JX0C5JGY1sWLfE2bnu4L3XPZhPmD7HhP5ZN54S6mgQZspDhhjnIn XqOiPf5Z3qm9E1O1ZYr8JsfyBs3XARnKf18UwuOE4HWu0uRY/E3bVh6wViHE2tbz 3fKQWXam5/IUBspZ7SR5H3UKqtMX4QdtadGggmuDlpCviWPUulmihfOziEzVYsHr G77eEZkYs5e32RhNcg+4RqYvB8YXyutIOCMl7xb6ZXQk0ImuqbxeGi5qaAaItRSa 1rzwCWfzTbA= =dAD1 -----END PGP SIGNATURE----- Fri Sep 19 13:15:06 UTC 2025 I: Checking whether the package is not for us Fri Sep 19 13:15:06 UTC 2025 I: Starting 1st build on remote node ionos5-amd64.debian.net. Fri Sep 19 13:15:06 UTC 2025 I: Preparing to do remote build '1' on ionos5-amd64.debian.net. Fri Sep 19 13:15:06 UTC 2025 - checking /var/lib/jenkins/offline_nodes if ionos5-amd64.debian.net is marked as down. Fri Sep 19 13:15:06 UTC 2025 - checking via ssh if ionos5-amd64.debian.net is up. removed '/tmp/read-only-fs-test-GAtZq9' ==================================================================================== Thu Oct 22 19:38:06 UTC 2026 - running /srv/jenkins/bin/reproducible_build.sh (for job /srv/jenkins/bin/reproducible_build.sh) on ionos5-amd64, called using "1 python-aiostream unstable /srv/reproducible-results/rbuild-debian/r-b-build.WT9ennms 0.5.2-2" as arguments. Thu Oct 22 19:38:06 UTC 2026 - actually running "reproducible_build.sh" (md5sum cc591790ab2c8e13f5e554202b95c89c) as "/tmp/jenkins-script-M40qWlhO" $ git clone https://salsa.debian.org/qa/jenkins.debian.net.git ; more CONTRIBUTING Thu Oct 22 19:38:06 UTC 2026 I: Downloading source for unstable/python-aiostream=0.5.2-2 Reading package lists... NOTICE: 'python-aiostream' packaging is maintained in the 'Git' version control system at: https://salsa.debian.org/python-team/packages/python-aiostream.git Please use: git clone https://salsa.debian.org/python-team/packages/python-aiostream.git to retrieve the latest (possibly unreleased) updates to the package. Need to get 41.7 kB of source archives. Get:1 http://deb.debian.org/debian unstable/main python-aiostream 0.5.2-2 (dsc) [2210 B] Get:2 http://deb.debian.org/debian unstable/main python-aiostream 0.5.2-2 (tar) [37.4 kB] Get:3 http://deb.debian.org/debian unstable/main python-aiostream 0.5.2-2 (diff) [2168 B] Fetched 41.7 kB in 0s (3166 kB/s) Download complete and in download only mode Reading package lists... NOTICE: 'python-aiostream' packaging is maintained in the 'Git' version control system at: https://salsa.debian.org/python-team/packages/python-aiostream.git Please use: git clone https://salsa.debian.org/python-team/packages/python-aiostream.git to retrieve the latest (possibly unreleased) updates to the package. Need to get 41.7 kB of source archives. Get:1 http://deb.debian.org/debian unstable/main python-aiostream 0.5.2-2 (dsc) [2210 B] Get:2 http://deb.debian.org/debian unstable/main python-aiostream 0.5.2-2 (tar) [37.4 kB] Get:3 http://deb.debian.org/debian unstable/main python-aiostream 0.5.2-2 (diff) [2168 B] Fetched 41.7 kB in 0s (3166 kB/s) Download complete and in download only mode ============================================================================= Building python-aiostream in unstable on amd64 on ionos5-amd64 now. Date: Thu Oct 22 19:38:07 UTC 2026 Date UTC: Thu Oct 22 19:38:07 UTC 2026 ============================================================================= W: /root/.pbuilderrc does not exist I: Logging to b1/build.log I: pbuilder: network access will be disabled during build I: Current time: Thu Oct 22 07:38:07 -12 2026 I: pbuilder-time-stamp: 1792697887 I: Building the build Environment I: extracting base tarball [/var/cache/pbuilder/unstable-reproducible-base.tgz] I: copying local configuration W: --override-config is not set; not updating apt.conf Read the manpage for details. I: mounting /proc filesystem I: mounting /sys filesystem I: creating /{dev,run}/shm I: mounting /dev/pts filesystem I: redirecting /dev/ptmx to /dev/pts/ptmx I: policy-rc.d already exists I: Copying source file I: copying [python-aiostream_0.5.2-2.dsc] I: copying [./python-aiostream_0.5.2.orig.tar.xz] I: copying [./python-aiostream_0.5.2-2.debian.tar.xz] I: Extracting source dpkg-source: warning: cannot verify inline signature for ./python-aiostream_0.5.2-2.dsc: no acceptable signature found dpkg-source: info: extracting python-aiostream in python-aiostream-0.5.2 dpkg-source: info: unpacking python-aiostream_0.5.2.orig.tar.xz dpkg-source: info: unpacking python-aiostream_0.5.2-2.debian.tar.xz I: Not using root during the build. I: Installing the build-deps I: user script /srv/workspace/pbuilder/2158390/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='amd64' DEBIAN_FRONTEND='noninteractive' DEB_BUILD_OPTIONS='buildinfo=+all reproducible=+all parallel=42 ' DISTRIBUTION='unstable' HOME='/root' HOST_ARCH='amd64' IFS=' ' INVOCATION_ID='961b956feceb4cfc825395c9461eb693' LANG='C' LANGUAGE='en_US:en' LC_ALL='C' 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='2158390' PS1='# ' PS2='> ' 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.WT9ennms/pbuilderrc_4SgS --distribution unstable --hookdir /etc/pbuilder/first-build-hooks --debbuildopts -b --basetgz /var/cache/pbuilder/unstable-reproducible-base.tgz --buildresult /srv/reproducible-results/rbuild-debian/r-b-build.WT9ennms/b1 --logfile b1/build.log python-aiostream_0.5.2-2.dsc' SUDO_GID='110' SUDO_HOME='/var/lib/jenkins' SUDO_UID='105' SUDO_USER='jenkins' TERM='unknown' TZ='/usr/share/zoneinfo/Etc/GMT+12' USER='root' _='/usr/bin/systemd-run' http_proxy='http://213.165.73.152:3128' I: uname -a Linux ionos5-amd64 6.12.43+deb13-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.12.43-1 (2025-08-27) x86_64 GNU/Linux I: ls -l /bin lrwxrwxrwx 1 root root 7 Aug 10 2025 /bin -> usr/bin I: user script /srv/workspace/pbuilder/2158390/tmp/hooks/D02_print_environment finished -> Attempting to satisfy build-dependencies -> Creating pbuilder-satisfydepends-dummy package Package: pbuilder-satisfydepends-dummy Version: 0.invalid.0 Architecture: amd64 Maintainer: Debian Pbuilder Team Description: Dummy package to satisfy dependencies with aptitude - created by pbuilder This package was created automatically by pbuilder to satisfy the build-dependencies of the package being currently built. Depends: debhelper-compat (= 13), dh-sequence-python3, python3-all, python3-pytest, python3-pytest-asyncio, python3-pytest-cov, python3-pytest-runner, python3-typing-extensions dpkg-deb: building package 'pbuilder-satisfydepends-dummy' in '/tmp/satisfydepends-aptitude/pbuilder-satisfydepends-dummy.deb'. Selecting previously unselected package pbuilder-satisfydepends-dummy. (Reading database ... 19917 files and directories currently installed.) Preparing to unpack .../pbuilder-satisfydepends-dummy.deb ... Unpacking pbuilder-satisfydepends-dummy (0.invalid.0) ... dpkg: pbuilder-satisfydepends-dummy: dependency problems, but configuring anyway as you requested: pbuilder-satisfydepends-dummy depends on debhelper-compat (= 13); however: Package debhelper-compat is not installed. pbuilder-satisfydepends-dummy depends on dh-sequence-python3; however: Package dh-sequence-python3 is not installed. pbuilder-satisfydepends-dummy depends on python3-all; however: Package python3-all is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest; however: Package python3-pytest is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest-asyncio; however: Package python3-pytest-asyncio is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest-cov; however: Package python3-pytest-cov is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest-runner; however: Package python3-pytest-runner is not installed. pbuilder-satisfydepends-dummy depends on python3-typing-extensions; however: Package python3-typing-extensions is not installed. Setting up pbuilder-satisfydepends-dummy (0.invalid.0) ... Reading package lists... Building dependency tree... Reading state information... Initializing package states... Writing extended state information... Building tag database... pbuilder-satisfydepends-dummy is already installed at the requested version (0.invalid.0) pbuilder-satisfydepends-dummy is already installed at the requested version (0.invalid.0) The following NEW packages will be installed: autoconf{a} automake{a} autopoint{a} autotools-dev{a} bsdextrautils{a} debhelper{a} dh-autoreconf{a} dh-python{a} dh-strip-nondeterminism{a} dwz{a} file{a} gettext{a} gettext-base{a} groff-base{a} intltool-debian{a} libarchive-zip-perl{a} libdebhelper-perl{a} libelf1t64{a} libexpat1{a} libffi8{a} libfile-stripnondeterminism-perl{a} libjs-jquery{a} libjs-jquery-hotkeys{a} libjs-jquery-isonscreen{a} libjs-jquery-metadata{a} libjs-jquery-tablesorter{a} libjs-jquery-throttle-debounce{a} libmagic-mgc{a} libmagic1t64{a} libpipeline1{a} libpython3-stdlib{a} libpython3.13-minimal{a} libpython3.13-stdlib{a} libreadline8t64{a} libtool{a} libuchardet0{a} libunistring5{a} libxml2-16{a} m4{a} man-db{a} media-types{a} netbase{a} po-debconf{a} python3{a} python3-all{a} python3-async-generator{a} python3-autocommand{a} python3-coverage{a} python3-inflect{a} python3-iniconfig{a} python3-jaraco.context{a} python3-jaraco.functools{a} python3-jaraco.text{a} python3-minimal{a} python3-more-itertools{a} python3-packaging{a} python3-pkg-resources{a} python3-pluggy{a} python3-pygments{a} python3-pytest{a} python3-pytest-asyncio{a} python3-pytest-cov{a} python3-pytest-runner{a} python3-setuptools{a} python3-typeguard{a} python3-typing-extensions{a} python3-zipp{a} python3.13{a} python3.13-minimal{a} readline-common{a} sensible-utils{a} tzdata{a} The following packages are RECOMMENDED but will NOT be installed: ca-certificates curl javascript-common libarchive-cpio-perl libltdl-dev libmail-sendmail-perl lynx wget 0 packages upgraded, 72 newly installed, 0 to remove and 0 not upgraded. Need to get 21.1 MB of archives. After unpacking 84.3 MB will be used. Writing extended state information... Get: 1 http://deb.debian.org/debian unstable/main amd64 libexpat1 amd64 2.7.2-1 [111 kB] Get: 2 http://deb.debian.org/debian unstable/main amd64 libpython3.13-minimal amd64 3.13.7-1 [864 kB] Get: 3 http://deb.debian.org/debian unstable/main amd64 python3.13-minimal amd64 3.13.7-1 [2216 kB] Get: 4 http://deb.debian.org/debian unstable/main amd64 python3-minimal amd64 3.13.7-1 [27.2 kB] Get: 5 http://deb.debian.org/debian unstable/main amd64 media-types all 13.0.0 [29.3 kB] Get: 6 http://deb.debian.org/debian unstable/main amd64 netbase all 6.5 [12.4 kB] Get: 7 http://deb.debian.org/debian unstable/main amd64 tzdata all 2025b-5 [260 kB] Get: 8 http://deb.debian.org/debian unstable/main amd64 libffi8 amd64 3.5.2-2 [25.5 kB] Get: 9 http://deb.debian.org/debian unstable/main amd64 readline-common all 8.3-3 [74.8 kB] Get: 10 http://deb.debian.org/debian unstable/main amd64 libreadline8t64 amd64 8.3-3 [191 kB] Get: 11 http://deb.debian.org/debian unstable/main amd64 libpython3.13-stdlib amd64 3.13.7-1 [1960 kB] Get: 12 http://deb.debian.org/debian unstable/main amd64 python3.13 amd64 3.13.7-1 [761 kB] Get: 13 http://deb.debian.org/debian unstable/main amd64 libpython3-stdlib amd64 3.13.7-1 [10.2 kB] Get: 14 http://deb.debian.org/debian unstable/main amd64 python3 amd64 3.13.7-1 [28.3 kB] Get: 15 http://deb.debian.org/debian unstable/main amd64 sensible-utils all 0.0.26 [27.0 kB] Get: 16 http://deb.debian.org/debian unstable/main amd64 libmagic-mgc amd64 1:5.46-5 [338 kB] Get: 17 http://deb.debian.org/debian unstable/main amd64 libmagic1t64 amd64 1:5.46-5 [109 kB] Get: 18 http://deb.debian.org/debian unstable/main amd64 file amd64 1:5.46-5 [43.6 kB] Get: 19 http://deb.debian.org/debian unstable/main amd64 gettext-base amd64 0.23.1-2+b1 [244 kB] Get: 20 http://deb.debian.org/debian unstable/main amd64 libuchardet0 amd64 0.0.8-2 [68.5 kB] Get: 21 http://deb.debian.org/debian unstable/main amd64 groff-base amd64 1.23.0-9 [1187 kB] Get: 22 http://deb.debian.org/debian unstable/main amd64 bsdextrautils amd64 2.41.1-3 [100 kB] Get: 23 http://deb.debian.org/debian unstable/main amd64 libpipeline1 amd64 1.5.8-1 [42.0 kB] Get: 24 http://deb.debian.org/debian unstable/main amd64 man-db amd64 2.13.1-1 [1469 kB] Get: 25 http://deb.debian.org/debian unstable/main amd64 m4 amd64 1.4.20-1 [324 kB] Get: 26 http://deb.debian.org/debian unstable/main amd64 autoconf all 2.72-3.1 [494 kB] Get: 27 http://deb.debian.org/debian unstable/main amd64 autotools-dev all 20240727.1 [60.2 kB] Get: 28 http://deb.debian.org/debian unstable/main amd64 automake all 1:1.17-4 [862 kB] Get: 29 http://deb.debian.org/debian unstable/main amd64 autopoint all 0.23.1-2 [770 kB] Get: 30 http://deb.debian.org/debian unstable/main amd64 libdebhelper-perl all 13.26 [91.8 kB] Get: 31 http://deb.debian.org/debian unstable/main amd64 libtool all 2.5.4-5 [540 kB] Get: 32 http://deb.debian.org/debian unstable/main amd64 dh-autoreconf all 21 [12.2 kB] Get: 33 http://deb.debian.org/debian unstable/main amd64 libarchive-zip-perl all 1.68-1 [104 kB] Get: 34 http://deb.debian.org/debian unstable/main amd64 libfile-stripnondeterminism-perl all 1.15.0-1 [19.9 kB] Get: 35 http://deb.debian.org/debian unstable/main amd64 dh-strip-nondeterminism all 1.15.0-1 [8812 B] Get: 36 http://deb.debian.org/debian unstable/main amd64 libelf1t64 amd64 0.193-3 [192 kB] Get: 37 http://deb.debian.org/debian unstable/main amd64 dwz amd64 0.16-2 [108 kB] Get: 38 http://deb.debian.org/debian unstable/main amd64 libunistring5 amd64 1.3-2 [477 kB] Get: 39 http://deb.debian.org/debian unstable/main amd64 libxml2-16 amd64 2.14.5+dfsg-0.2 [638 kB] Get: 40 http://deb.debian.org/debian unstable/main amd64 gettext amd64 0.23.1-2+b1 [1680 kB] Get: 41 http://deb.debian.org/debian unstable/main amd64 intltool-debian all 0.35.0+20060710.6 [22.9 kB] Get: 42 http://deb.debian.org/debian unstable/main amd64 po-debconf all 1.0.21+nmu1 [248 kB] Get: 43 http://deb.debian.org/debian unstable/main amd64 debhelper all 13.26 [939 kB] Get: 44 http://deb.debian.org/debian unstable/main amd64 dh-python all 6.20250414 [116 kB] Get: 45 http://deb.debian.org/debian unstable/main amd64 libjs-jquery all 3.7.1+dfsg+~3.5.33-1 [319 kB] Get: 46 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-hotkeys all 0.2.0-1 [12.6 kB] Get: 47 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-isonscreen all 1.2.0-1.1 [3196 B] Get: 48 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-metadata all 12-4 [6532 B] Get: 49 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-tablesorter all 1:2.31.3+dfsg1-4 [184 kB] Get: 50 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-throttle-debounce all 1.1+dfsg.1-2 [12.2 kB] Get: 51 http://deb.debian.org/debian unstable/main amd64 python3-all amd64 3.13.7-1 [1048 B] Get: 52 http://deb.debian.org/debian unstable/main amd64 python3-async-generator all 1.10-4 [17.4 kB] Get: 53 http://deb.debian.org/debian unstable/main amd64 python3-autocommand all 2.2.2-3 [13.6 kB] Get: 54 http://deb.debian.org/debian unstable/main amd64 python3-coverage amd64 7.8.2+dfsg1-1 [182 kB] Get: 55 http://deb.debian.org/debian unstable/main amd64 python3-more-itertools all 10.8.0-1 [71.7 kB] Get: 56 http://deb.debian.org/debian unstable/main amd64 python3-typing-extensions all 4.15.0-1 [92.4 kB] Get: 57 http://deb.debian.org/debian unstable/main amd64 python3-typeguard all 4.4.4-1 [37.1 kB] Get: 58 http://deb.debian.org/debian unstable/main amd64 python3-inflect all 7.5.0-1 [33.0 kB] Get: 59 http://deb.debian.org/debian unstable/main amd64 python3-iniconfig all 1.1.1-2 [6396 B] Get: 60 http://deb.debian.org/debian unstable/main amd64 python3-jaraco.functools all 4.1.0-1 [12.0 kB] Get: 61 http://deb.debian.org/debian unstable/main amd64 python3-pkg-resources all 78.1.1-0.1 [224 kB] Get: 62 http://deb.debian.org/debian unstable/main amd64 python3-jaraco.text all 4.0.0-1 [11.4 kB] Get: 63 http://deb.debian.org/debian unstable/main amd64 python3-zipp all 3.23.0-1 [11.0 kB] Get: 64 http://deb.debian.org/debian unstable/main amd64 python3-setuptools all 78.1.1-0.1 [738 kB] Get: 65 http://deb.debian.org/debian unstable/main amd64 python3-jaraco.context all 6.0.1-1 [8276 B] Get: 66 http://deb.debian.org/debian unstable/main amd64 python3-packaging all 25.0-1 [56.6 kB] Get: 67 http://deb.debian.org/debian unstable/main amd64 python3-pluggy all 1.6.0-1 [27.1 kB] Get: 68 http://deb.debian.org/debian unstable/main amd64 python3-pygments all 2.18.0+dfsg-2 [836 kB] Get: 69 http://deb.debian.org/debian unstable/main amd64 python3-pytest all 8.4.2-1 [266 kB] Get: 70 http://deb.debian.org/debian unstable/main amd64 python3-pytest-asyncio all 1.1.0-2 [13.1 kB] Get: 71 http://deb.debian.org/debian unstable/main amd64 python3-pytest-cov all 5.0.0-1 [26.8 kB] Get: 72 http://deb.debian.org/debian unstable/main amd64 python3-pytest-runner all 2.11.1-4 [8432 B] Fetched 21.1 MB in 0s (120 MB/s) Preconfiguring packages ... Selecting previously unselected package libexpat1:amd64. (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 ... 19917 files and directories currently installed.) Preparing to unpack .../libexpat1_2.7.2-1_amd64.deb ... Unpacking libexpat1:amd64 (2.7.2-1) ... Selecting previously unselected package libpython3.13-minimal:amd64. Preparing to unpack .../libpython3.13-minimal_3.13.7-1_amd64.deb ... Unpacking libpython3.13-minimal:amd64 (3.13.7-1) ... Selecting previously unselected package python3.13-minimal. Preparing to unpack .../python3.13-minimal_3.13.7-1_amd64.deb ... Unpacking python3.13-minimal (3.13.7-1) ... Setting up libpython3.13-minimal:amd64 (3.13.7-1) ... Setting up libexpat1:amd64 (2.7.2-1) ... Setting up python3.13-minimal (3.13.7-1) ... Selecting previously unselected package python3-minimal. (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 ... 20251 files and directories currently installed.) Preparing to unpack .../0-python3-minimal_3.13.7-1_amd64.deb ... Unpacking python3-minimal (3.13.7-1) ... Selecting previously unselected package media-types. Preparing to unpack .../1-media-types_13.0.0_all.deb ... Unpacking media-types (13.0.0) ... Selecting previously unselected package netbase. Preparing to unpack .../2-netbase_6.5_all.deb ... Unpacking netbase (6.5) ... Selecting previously unselected package tzdata. Preparing to unpack .../3-tzdata_2025b-5_all.deb ... Unpacking tzdata (2025b-5) ... Selecting previously unselected package libffi8:amd64. Preparing to unpack .../4-libffi8_3.5.2-2_amd64.deb ... Unpacking libffi8:amd64 (3.5.2-2) ... Selecting previously unselected package readline-common. Preparing to unpack .../5-readline-common_8.3-3_all.deb ... Unpacking readline-common (8.3-3) ... Selecting previously unselected package libreadline8t64:amd64. Preparing to unpack .../6-libreadline8t64_8.3-3_amd64.deb ... Adding 'diversion of /lib/x86_64-linux-gnu/libhistory.so.8 to /lib/x86_64-linux-gnu/libhistory.so.8.usr-is-merged by libreadline8t64' Adding 'diversion of /lib/x86_64-linux-gnu/libhistory.so.8.2 to /lib/x86_64-linux-gnu/libhistory.so.8.2.usr-is-merged by libreadline8t64' Adding 'diversion of /lib/x86_64-linux-gnu/libreadline.so.8 to /lib/x86_64-linux-gnu/libreadline.so.8.usr-is-merged by libreadline8t64' Adding 'diversion of /lib/x86_64-linux-gnu/libreadline.so.8.2 to /lib/x86_64-linux-gnu/libreadline.so.8.2.usr-is-merged by libreadline8t64' Unpacking libreadline8t64:amd64 (8.3-3) ... Selecting previously unselected package libpython3.13-stdlib:amd64. Preparing to unpack .../7-libpython3.13-stdlib_3.13.7-1_amd64.deb ... Unpacking libpython3.13-stdlib:amd64 (3.13.7-1) ... Selecting previously unselected package python3.13. Preparing to unpack .../8-python3.13_3.13.7-1_amd64.deb ... Unpacking python3.13 (3.13.7-1) ... Selecting previously unselected package libpython3-stdlib:amd64. Preparing to unpack .../9-libpython3-stdlib_3.13.7-1_amd64.deb ... Unpacking libpython3-stdlib:amd64 (3.13.7-1) ... Setting up python3-minimal (3.13.7-1) ... Selecting previously unselected package python3. (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 ... 21266 files and directories currently installed.) Preparing to unpack .../00-python3_3.13.7-1_amd64.deb ... Unpacking python3 (3.13.7-1) ... Selecting previously unselected package sensible-utils. Preparing to unpack .../01-sensible-utils_0.0.26_all.deb ... Unpacking sensible-utils (0.0.26) ... Selecting previously unselected package libmagic-mgc. Preparing to unpack .../02-libmagic-mgc_1%3a5.46-5_amd64.deb ... Unpacking libmagic-mgc (1:5.46-5) ... Selecting previously unselected package libmagic1t64:amd64. Preparing to unpack .../03-libmagic1t64_1%3a5.46-5_amd64.deb ... Unpacking libmagic1t64:amd64 (1:5.46-5) ... Selecting previously unselected package file. Preparing to unpack .../04-file_1%3a5.46-5_amd64.deb ... Unpacking file (1:5.46-5) ... Selecting previously unselected package gettext-base. Preparing to unpack .../05-gettext-base_0.23.1-2+b1_amd64.deb ... Unpacking gettext-base (0.23.1-2+b1) ... Selecting previously unselected package libuchardet0:amd64. Preparing to unpack .../06-libuchardet0_0.0.8-2_amd64.deb ... Unpacking libuchardet0:amd64 (0.0.8-2) ... Selecting previously unselected package groff-base. Preparing to unpack .../07-groff-base_1.23.0-9_amd64.deb ... Unpacking groff-base (1.23.0-9) ... Selecting previously unselected package bsdextrautils. Preparing to unpack .../08-bsdextrautils_2.41.1-3_amd64.deb ... Unpacking bsdextrautils (2.41.1-3) ... Selecting previously unselected package libpipeline1:amd64. Preparing to unpack .../09-libpipeline1_1.5.8-1_amd64.deb ... Unpacking libpipeline1:amd64 (1.5.8-1) ... Selecting previously unselected package man-db. Preparing to unpack .../10-man-db_2.13.1-1_amd64.deb ... Unpacking man-db (2.13.1-1) ... Selecting previously unselected package m4. Preparing to unpack .../11-m4_1.4.20-1_amd64.deb ... Unpacking m4 (1.4.20-1) ... Selecting previously unselected package autoconf. Preparing to unpack .../12-autoconf_2.72-3.1_all.deb ... Unpacking autoconf (2.72-3.1) ... Selecting previously unselected package autotools-dev. Preparing to unpack .../13-autotools-dev_20240727.1_all.deb ... Unpacking autotools-dev (20240727.1) ... Selecting previously unselected package automake. Preparing to unpack .../14-automake_1%3a1.17-4_all.deb ... Unpacking automake (1:1.17-4) ... Selecting previously unselected package autopoint. Preparing to unpack .../15-autopoint_0.23.1-2_all.deb ... Unpacking autopoint (0.23.1-2) ... Selecting previously unselected package libdebhelper-perl. Preparing to unpack .../16-libdebhelper-perl_13.26_all.deb ... Unpacking libdebhelper-perl (13.26) ... Selecting previously unselected package libtool. Preparing to unpack .../17-libtool_2.5.4-5_all.deb ... Unpacking libtool (2.5.4-5) ... Selecting previously unselected package dh-autoreconf. Preparing to unpack .../18-dh-autoreconf_21_all.deb ... Unpacking dh-autoreconf (21) ... Selecting previously unselected package libarchive-zip-perl. Preparing to unpack .../19-libarchive-zip-perl_1.68-1_all.deb ... Unpacking libarchive-zip-perl (1.68-1) ... Selecting previously unselected package libfile-stripnondeterminism-perl. Preparing to unpack .../20-libfile-stripnondeterminism-perl_1.15.0-1_all.deb ... Unpacking libfile-stripnondeterminism-perl (1.15.0-1) ... Selecting previously unselected package dh-strip-nondeterminism. Preparing to unpack .../21-dh-strip-nondeterminism_1.15.0-1_all.deb ... Unpacking dh-strip-nondeterminism (1.15.0-1) ... Selecting previously unselected package libelf1t64:amd64. Preparing to unpack .../22-libelf1t64_0.193-3_amd64.deb ... Unpacking libelf1t64:amd64 (0.193-3) ... Selecting previously unselected package dwz. Preparing to unpack .../23-dwz_0.16-2_amd64.deb ... Unpacking dwz (0.16-2) ... Selecting previously unselected package libunistring5:amd64. Preparing to unpack .../24-libunistring5_1.3-2_amd64.deb ... Unpacking libunistring5:amd64 (1.3-2) ... Selecting previously unselected package libxml2-16:amd64. Preparing to unpack .../25-libxml2-16_2.14.5+dfsg-0.2_amd64.deb ... Unpacking libxml2-16:amd64 (2.14.5+dfsg-0.2) ... Selecting previously unselected package gettext. Preparing to unpack .../26-gettext_0.23.1-2+b1_amd64.deb ... Unpacking gettext (0.23.1-2+b1) ... Selecting previously unselected package intltool-debian. Preparing to unpack .../27-intltool-debian_0.35.0+20060710.6_all.deb ... Unpacking intltool-debian (0.35.0+20060710.6) ... Selecting previously unselected package po-debconf. Preparing to unpack .../28-po-debconf_1.0.21+nmu1_all.deb ... Unpacking po-debconf (1.0.21+nmu1) ... Selecting previously unselected package debhelper. Preparing to unpack .../29-debhelper_13.26_all.deb ... Unpacking debhelper (13.26) ... Selecting previously unselected package dh-python. Preparing to unpack .../30-dh-python_6.20250414_all.deb ... Unpacking dh-python (6.20250414) ... Selecting previously unselected package libjs-jquery. Preparing to unpack .../31-libjs-jquery_3.7.1+dfsg+~3.5.33-1_all.deb ... Unpacking libjs-jquery (3.7.1+dfsg+~3.5.33-1) ... Selecting previously unselected package libjs-jquery-hotkeys. Preparing to unpack .../32-libjs-jquery-hotkeys_0.2.0-1_all.deb ... Unpacking libjs-jquery-hotkeys (0.2.0-1) ... Selecting previously unselected package libjs-jquery-isonscreen. Preparing to unpack .../33-libjs-jquery-isonscreen_1.2.0-1.1_all.deb ... Unpacking libjs-jquery-isonscreen (1.2.0-1.1) ... Selecting previously unselected package libjs-jquery-metadata. Preparing to unpack .../34-libjs-jquery-metadata_12-4_all.deb ... Unpacking libjs-jquery-metadata (12-4) ... Selecting previously unselected package libjs-jquery-tablesorter. Preparing to unpack .../35-libjs-jquery-tablesorter_1%3a2.31.3+dfsg1-4_all.deb ... Unpacking libjs-jquery-tablesorter (1:2.31.3+dfsg1-4) ... Selecting previously unselected package libjs-jquery-throttle-debounce. Preparing to unpack .../36-libjs-jquery-throttle-debounce_1.1+dfsg.1-2_all.deb ... Unpacking libjs-jquery-throttle-debounce (1.1+dfsg.1-2) ... Selecting previously unselected package python3-all. Preparing to unpack .../37-python3-all_3.13.7-1_amd64.deb ... Unpacking python3-all (3.13.7-1) ... Selecting previously unselected package python3-async-generator. Preparing to unpack .../38-python3-async-generator_1.10-4_all.deb ... Unpacking python3-async-generator (1.10-4) ... Selecting previously unselected package python3-autocommand. Preparing to unpack .../39-python3-autocommand_2.2.2-3_all.deb ... Unpacking python3-autocommand (2.2.2-3) ... Selecting previously unselected package python3-coverage. Preparing to unpack .../40-python3-coverage_7.8.2+dfsg1-1_amd64.deb ... Unpacking python3-coverage (7.8.2+dfsg1-1) ... Selecting previously unselected package python3-more-itertools. Preparing to unpack .../41-python3-more-itertools_10.8.0-1_all.deb ... Unpacking python3-more-itertools (10.8.0-1) ... Selecting previously unselected package python3-typing-extensions. Preparing to unpack .../42-python3-typing-extensions_4.15.0-1_all.deb ... Unpacking python3-typing-extensions (4.15.0-1) ... Selecting previously unselected package python3-typeguard. Preparing to unpack .../43-python3-typeguard_4.4.4-1_all.deb ... Unpacking python3-typeguard (4.4.4-1) ... Selecting previously unselected package python3-inflect. Preparing to unpack .../44-python3-inflect_7.5.0-1_all.deb ... Unpacking python3-inflect (7.5.0-1) ... Selecting previously unselected package python3-iniconfig. Preparing to unpack .../45-python3-iniconfig_1.1.1-2_all.deb ... Unpacking python3-iniconfig (1.1.1-2) ... Selecting previously unselected package python3-jaraco.functools. Preparing to unpack .../46-python3-jaraco.functools_4.1.0-1_all.deb ... Unpacking python3-jaraco.functools (4.1.0-1) ... Selecting previously unselected package python3-pkg-resources. Preparing to unpack .../47-python3-pkg-resources_78.1.1-0.1_all.deb ... Unpacking python3-pkg-resources (78.1.1-0.1) ... Selecting previously unselected package python3-jaraco.text. Preparing to unpack .../48-python3-jaraco.text_4.0.0-1_all.deb ... Unpacking python3-jaraco.text (4.0.0-1) ... Selecting previously unselected package python3-zipp. Preparing to unpack .../49-python3-zipp_3.23.0-1_all.deb ... Unpacking python3-zipp (3.23.0-1) ... Selecting previously unselected package python3-setuptools. Preparing to unpack .../50-python3-setuptools_78.1.1-0.1_all.deb ... Unpacking python3-setuptools (78.1.1-0.1) ... Selecting previously unselected package python3-jaraco.context. Preparing to unpack .../51-python3-jaraco.context_6.0.1-1_all.deb ... Unpacking python3-jaraco.context (6.0.1-1) ... Selecting previously unselected package python3-packaging. Preparing to unpack .../52-python3-packaging_25.0-1_all.deb ... Unpacking python3-packaging (25.0-1) ... Selecting previously unselected package python3-pluggy. Preparing to unpack .../53-python3-pluggy_1.6.0-1_all.deb ... Unpacking python3-pluggy (1.6.0-1) ... Selecting previously unselected package python3-pygments. Preparing to unpack .../54-python3-pygments_2.18.0+dfsg-2_all.deb ... Unpacking python3-pygments (2.18.0+dfsg-2) ... Selecting previously unselected package python3-pytest. Preparing to unpack .../55-python3-pytest_8.4.2-1_all.deb ... Unpacking python3-pytest (8.4.2-1) ... Selecting previously unselected package python3-pytest-asyncio. Preparing to unpack .../56-python3-pytest-asyncio_1.1.0-2_all.deb ... Unpacking python3-pytest-asyncio (1.1.0-2) ... Selecting previously unselected package python3-pytest-cov. Preparing to unpack .../57-python3-pytest-cov_5.0.0-1_all.deb ... Unpacking python3-pytest-cov (5.0.0-1) ... Selecting previously unselected package python3-pytest-runner. Preparing to unpack .../58-python3-pytest-runner_2.11.1-4_all.deb ... Unpacking python3-pytest-runner (2.11.1-4) ... Setting up media-types (13.0.0) ... Setting up libpipeline1:amd64 (1.5.8-1) ... Setting up bsdextrautils (2.41.1-3) ... Setting up libmagic-mgc (1:5.46-5) ... Setting up libarchive-zip-perl (1.68-1) ... Setting up libxml2-16:amd64 (2.14.5+dfsg-0.2) ... Setting up libdebhelper-perl (13.26) ... Setting up libmagic1t64:amd64 (1:5.46-5) ... Setting up gettext-base (0.23.1-2+b1) ... Setting up m4 (1.4.20-1) ... Setting up file (1:5.46-5) ... Setting up libjs-jquery-throttle-debounce (1.1+dfsg.1-2) ... Setting up libelf1t64:amd64 (0.193-3) ... Setting up tzdata (2025b-5) ... Current default time zone: 'Etc/UTC' Local time is now: Thu Oct 22 19:38:38 UTC 2026. Universal Time is now: Thu Oct 22 19:38:38 UTC 2026. Run 'dpkg-reconfigure tzdata' if you wish to change it. Setting up autotools-dev (20240727.1) ... Setting up libunistring5:amd64 (1.3-2) ... Setting up autopoint (0.23.1-2) ... Setting up autoconf (2.72-3.1) ... Setting up libffi8:amd64 (3.5.2-2) ... Setting up dwz (0.16-2) ... Setting up sensible-utils (0.0.26) ... Setting up libuchardet0:amd64 (0.0.8-2) ... Setting up netbase (6.5) ... Setting up libjs-jquery (3.7.1+dfsg+~3.5.33-1) ... Setting up libjs-jquery-hotkeys (0.2.0-1) ... Setting up readline-common (8.3-3) ... Setting up automake (1:1.17-4) ... update-alternatives: using /usr/bin/automake-1.17 to provide /usr/bin/automake (automake) in auto mode Setting up libfile-stripnondeterminism-perl (1.15.0-1) ... Setting up gettext (0.23.1-2+b1) ... Setting up libtool (2.5.4-5) ... Setting up intltool-debian (0.35.0+20060710.6) ... Setting up dh-autoreconf (21) ... Setting up libjs-jquery-metadata (12-4) ... Setting up libjs-jquery-isonscreen (1.2.0-1.1) ... Setting up libreadline8t64:amd64 (8.3-3) ... Setting up dh-strip-nondeterminism (1.15.0-1) ... Setting up libjs-jquery-tablesorter (1:2.31.3+dfsg1-4) ... Setting up groff-base (1.23.0-9) ... Setting up libpython3.13-stdlib:amd64 (3.13.7-1) ... Setting up libpython3-stdlib:amd64 (3.13.7-1) ... Setting up python3.13 (3.13.7-1) ... Setting up po-debconf (1.0.21+nmu1) ... Setting up python3 (3.13.7-1) ... Setting up python3-zipp (3.23.0-1) ... Setting up python3-autocommand (2.2.2-3) ... Setting up man-db (2.13.1-1) ... Not building database; man-db/auto-update is not 'true'. Setting up python3-pygments (2.18.0+dfsg-2) ... Setting up python3-packaging (25.0-1) ... Setting up python3-typing-extensions (4.15.0-1) ... Setting up python3-pluggy (1.6.0-1) ... Setting up dh-python (6.20250414) ... Setting up python3-more-itertools (10.8.0-1) ... Setting up python3-iniconfig (1.1.1-2) ... Setting up python3-jaraco.functools (4.1.0-1) ... Setting up python3-async-generator (1.10-4) ... Setting up python3-jaraco.context (6.0.1-1) ... Setting up python3-pytest (8.4.2-1) ... Setting up python3-typeguard (4.4.4-1) ... Setting up python3-all (3.13.7-1) ... Setting up python3-coverage (7.8.2+dfsg1-1) ... Setting up debhelper (13.26) ... Setting up python3-pytest-cov (5.0.0-1) ... Setting up python3-inflect (7.5.0-1) ... Setting up python3-jaraco.text (4.0.0-1) ... Setting up python3-pytest-asyncio (1.1.0-2) ... Setting up python3-pkg-resources (78.1.1-0.1) ... Setting up python3-setuptools (78.1.1-0.1) ... Setting up python3-pytest-runner (2.11.1-4) ... Processing triggers for libc-bin (2.41-12) ... Reading package lists... Building dependency tree... Reading state information... Reading extended state information... Initializing package states... Writing extended state information... Building tag database... -> Finished parsing the build-deps I: Building the package I: Running cd /build/reproducible-path/python-aiostream-0.5.2/ && 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-aiostream_0.5.2-2_source.changes dpkg-buildpackage: info: source package python-aiostream dpkg-buildpackage: info: source version 0.5.2-2 dpkg-buildpackage: info: source distribution unstable dpkg-buildpackage: info: source changed by Alexandre Detiste dpkg-source --before-build . dpkg-buildpackage: info: host architecture amd64 dpkg-source: info: using options from python-aiostream-0.5.2/debian/source/options: --extend-diff-ignore=^[^/]+.egg-info/ debian/rules clean dh clean --buildsystem=pybuild dh_auto_clean -O--buildsystem=pybuild I: pybuild base:311: python3.13 setup.py clean /usr/lib/python3/dist-packages/setuptools/__init__.py:94: _DeprecatedInstaller: setuptools.installer and fetch_build_eggs are deprecated. !! ******************************************************************************** Requirements should be satisfied by a PEP 517 installer. If you are using pip, you can try `pip install --use-pep517`. ******************************************************************************** !! dist.fetch_build_eggs(dist.setup_requires) /usr/lib/python3/dist-packages/setuptools/_distutils/dist.py:289: UserWarning: Unknown distribution option: 'tests_require' warnings.warn(msg) running clean removing '/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build' (and everything under it) 'build/bdist.linux-x86_64' does not exist -- can't clean it 'build/scripts-3.13' does not exist -- can't clean it dh_autoreconf_clean -O--buildsystem=pybuild dh_clean -O--buildsystem=pybuild debian/rules binary dh binary --buildsystem=pybuild dh_update_autotools_config -O--buildsystem=pybuild dh_autoreconf -O--buildsystem=pybuild dh_auto_configure -O--buildsystem=pybuild I: pybuild base:311: python3.13 setup.py config /usr/lib/python3/dist-packages/setuptools/__init__.py:94: _DeprecatedInstaller: setuptools.installer and fetch_build_eggs are deprecated. !! ******************************************************************************** Requirements should be satisfied by a PEP 517 installer. If you are using pip, you can try `pip install --use-pep517`. ******************************************************************************** !! dist.fetch_build_eggs(dist.setup_requires) /usr/lib/python3/dist-packages/setuptools/_distutils/dist.py:289: UserWarning: Unknown distribution option: 'tests_require' warnings.warn(msg) running config dh_auto_build -O--buildsystem=pybuild I: pybuild base:311: /usr/bin/python3 setup.py build /usr/lib/python3/dist-packages/setuptools/__init__.py:94: _DeprecatedInstaller: setuptools.installer and fetch_build_eggs are deprecated. !! ******************************************************************************** Requirements should be satisfied by a PEP 517 installer. If you are using pip, you can try `pip install --use-pep517`. ******************************************************************************** !! dist.fetch_build_eggs(dist.setup_requires) /usr/lib/python3/dist-packages/setuptools/_distutils/dist.py:289: UserWarning: Unknown distribution option: 'tests_require' warnings.warn(msg) running build running build_py creating /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/manager.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/aiter_utils.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/__init__.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/pipe.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/core.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/test_utils.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream creating /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/select.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/aggregate.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/transform.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/time.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/create.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/__init__.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/advanced.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/combine.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/misc.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/py.typed -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream dh_auto_test -O--buildsystem=pybuild I: pybuild base:311: cd /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build; python3.13 -m pytest tests ============================= test session starts ============================== platform linux -- Python 3.13.7, pytest-8.4.2, pluggy-1.6.0 rootdir: /build/reproducible-path/python-aiostream-0.5.2 configfile: setup.cfg plugins: typeguard-4.4.4, cov-5.0.0, asyncio-1.1.0 asyncio: mode=Mode.STRICT, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function collected 97 items tests/test_advanced.py FFFFFF [ 6%] tests/test_aggregate.py FFFFFF [ 12%] tests/test_aiter.py F....... [ 20%] tests/test_combine.py FFFFFFFFFF [ 30%] tests/test_core.py F.... [ 36%] tests/test_create.py ........FF..FF....FF.... [ 60%] tests/test_misc.py FFFF [ 64%] tests/test_pipe.py . [ 65%] tests/test_select.py FFFFFFFFFFFFFFFFFFFFFFFF [ 90%] tests/test_task_group.py E [ 91%] tests/test_time.py FF [ 93%] tests/test_transform.py FFFFFF [100%] ==================================== ERRORS ==================================== __________________ ERROR at setup of test_task_group_cleanup ___________________ file /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/tests/test_task_group.py, line 34 @pytest.mark.asyncio async def test_task_group_cleanup(event_loop): async with TaskGroup() as group: t1 = group.create_task(task1()) t2 = group.create_task(task2()) t3 = group.create_task(task3()) t4 = group.create_task(task4()) t5 = group.create_task(task5()) # Cancel task1 t1.cancel() with pytest.raises(asyncio.CancelledError): await t1 assert t1.cancelled() # Join task2 assert await t2 == 2 # Task 3 is finished assert t3.done() # Task 4 and 5 are not finished assert not t4.done() assert not t5.done() E fixture 'event_loop' not found > available fixtures: _class_scoped_runner, _function_scoped_runner, _module_scoped_runner, _package_scoped_runner, _session_scoped_runner, cache, capfd, capfdbinary, caplog, capsys, capsysbinary, capteesys, cov, doctest_namespace, event_loop_policy, monkeypatch, no_cover, pytestconfig, record_property, record_testsuite_property, record_xml_attribute, recwarn, tmp_path, tmp_path_factory, tmpdir, tmpdir_factory, unused_tcp_port, unused_tcp_port_factory, unused_udp_port, unused_udp_port_factory > use 'pytest --fixtures [testpath]' for help on them. /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/tests/test_task_group.py:34 =================================== FAILURES =================================== ____________________________ test_concatmap[aiter] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_concatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.concatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 1, 2, 3, 4, 5]) > assert event_loop.steps == [1, 1, 3, 5, 5] E assert [] == [1, 1, 3, 5, 5] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:17: AssertionError ____________________________ test_concatmap[await] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_concatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.concatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 1, 2, 3, 4, 5]) > assert event_loop.steps == [1, 1, 3, 5, 5] E assert [] == [1, 1, 3, 5, 5] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:17: AssertionError _____________________________ test_flatmap[aiter] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_flatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.flatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 2, 4, 1, 3, 5]) > assert event_loop.steps == [1, 1, 3, 1, 1] E assert [] == [1, 1, 3, 1, 1] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:66: AssertionError _____________________________ test_flatmap[await] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_flatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.flatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 2, 4, 1, 3, 5]) > assert event_loop.steps == [1, 1, 3, 1, 1] E assert [] == [1, 1, 3, 1, 1] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:66: AssertionError ____________________________ test_switchmap[aiter] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_switchmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 30, 10, interval=3) ys = xs | pipe.switchmap(lambda x: stream.range(x, x + 5, interval=1)) await assert_run(ys, [0, 1, 2, 10, 11, 12, 20, 21, 22, 23, 24]) > assert event_loop.steps == [1, 1, 1, 1, 1, 1, 1, 1, 1, 1] E assert [] == [1, 1, 1, 1, 1, 1, ...] E E Right contains 10 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:93: AssertionError ____________________________ test_switchmap[await] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_switchmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 30, 10, interval=3) ys = xs | pipe.switchmap(lambda x: stream.range(x, x + 5, interval=1)) await assert_run(ys, [0, 1, 2, 10, 11, 12, 20, 21, 22, 23, 24]) > assert event_loop.steps == [1, 1, 1, 1, 1, 1, 1, 1, 1, 1] E assert [] == [1, 1, 1, 1, 1, 1, ...] E E Right contains 10 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:93: AssertionError ____________________________ test_aggregate[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_aggregate(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.accumulate() > await assert_run(xs, [0, 1, 3, 6, 10]) tests/test_aggregate.py:16: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_aggregate[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_aggregate(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.accumulate() > await assert_run(xs, [0, 1, 3, 6, 10]) tests/test_aggregate.py:16: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_reduce[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_reduce(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.reduce(min) > await assert_run(xs, [0]) tests/test_aggregate.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:56: in takelast async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_reduce[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_reduce(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.reduce(min) > await assert_run(xs, [0]) tests/test_aggregate.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:56: in takelast async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_list[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_list(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | add_resource.pipe(1) | pipe.list() # The same list object is yielded at each step > await assert_run(xs, [[0, 1, 2], [0, 1, 2], [0, 1, 2], [0, 1, 2]]) tests/test_aggregate.py:59: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/aggregate.py:88: in list async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_list[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_list(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | add_resource.pipe(1) | pipe.list() # The same list object is yielded at each step > await assert_run(xs, [[0, 1, 2], [0, 1, 2], [0, 1, 2], [0, 1, 2]]) tests/test_aggregate.py:59: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/aggregate.py:88: in list async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ___________________________ test_simple_aitercontext ___________________________ event_loop = @pytest.mark.asyncio async def test_simple_aitercontext(event_loop): async with aitercontext(agen()) as safe_gen: # Cannot enter twice with pytest.raises(RuntimeError): async with safe_gen: pass it = iter(range(5)) async for item in safe_gen: assert item == next(it) > assert event_loop.steps == [1] * 5 E assert [] == [1, 1, 1, 1, 1] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_aiter.py:68: AssertionError ______________________________ test_chain[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chain(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) + stream.range(5, 10) await assert_run(xs, list(range(10))) with event_loop.assert_cleanup(): xs = stream.range(10, 15) | add_resource.pipe(1) xs += stream.range(15, 20) | add_resource.pipe(1) > await assert_run(xs, list(range(10, 20))) tests/test_combine.py:20: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:47: in chain async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_chain[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chain(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) + stream.range(5, 10) await assert_run(xs, list(range(10))) with event_loop.assert_cleanup(): xs = stream.range(10, 15) | add_resource.pipe(1) xs += stream.range(15, 20) | add_resource.pipe(1) > await assert_run(xs, list(range(10, 20))) tests/test_combine.py:20: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:47: in chain async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_zip[aiter] ________________________________ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_zip(assert_run, event_loop): xs = stream.range(5) | add_resource.pipe(1.0) ys = xs | pipe.zip(xs, xs) expected = [(x,) * 3 for x in range(5)] > await assert_run(ys, expected) tests/test_combine.py:28: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:84: in zip items = await asyncio.gather(*coros) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_zip[await] ________________________________ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_zip(assert_run, event_loop): xs = stream.range(5) | add_resource.pipe(1.0) ys = xs | pipe.zip(xs, xs) expected = [(x,) * 3 for x in range(5)] > await assert_run(ys, expected) tests/test_combine.py:28: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:84: in zip items = await asyncio.gather(*coros) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_map[aiter] ________________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_map(assert_run, event_loop): # Synchronous/simple with event_loop.assert_cleanup(): xs = stream.range(5) | pipe.map(lambda x: x**2) expected = [x**2 for x in range(5)] await assert_run(xs, expected) # Synchronous/multiple with event_loop.assert_cleanup(): xs = stream.range(5) ys = xs | pipe.map(lambda x, y: x + y, xs) expected = [x * 2 for x in range(5)] await assert_run(ys, expected) # Asynchronous/simple/concurrent with event_loop.assert_cleanup(): xs = stream.range(1, 4) | pipe.map(asyncio.sleep) expected = [None] * 3 await assert_run(xs, expected) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:51: AssertionError _______________________________ test_map[await] ________________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_map(assert_run, event_loop): # Synchronous/simple with event_loop.assert_cleanup(): xs = stream.range(5) | pipe.map(lambda x: x**2) expected = [x**2 for x in range(5)] await assert_run(xs, expected) # Synchronous/multiple with event_loop.assert_cleanup(): xs = stream.range(5) ys = xs | pipe.map(lambda x, y: x + y, xs) expected = [x * 2 for x in range(5)] await assert_run(ys, expected) # Asynchronous/simple/concurrent with event_loop.assert_cleanup(): xs = stream.range(1, 4) | pipe.map(asyncio.sleep) expected = [None] * 3 await assert_run(xs, expected) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:51: AssertionError ______________________________ test_merge[aiter] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_merge(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 5, 2, interval=2) | pipe.delay(1) ys = stream.range(0, 5, 2, interval=2) | pipe.merge(xs) await assert_run(ys, [0, 1, 2, 3, 4]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:119: AssertionError ______________________________ test_merge[await] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_merge(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 5, 2, interval=2) | pipe.delay(1) ys = stream.range(0, 5, 2, interval=2) | pipe.merge(xs) await assert_run(ys, [0, 1, 2, 3, 4]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:119: AssertionError ____________________________ test_ziplatest[aiter] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_ziplatest(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 5, 2, interval=2) ys = stream.range(1, 5, 2, interval=2) | pipe.delay(1) zs = stream.ziplatest(xs, ys, default="▲") await assert_run(zs, [(0, "▲"), (0, 1), (2, 1), (2, 3), (4, 3)]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:171: AssertionError ____________________________ test_ziplatest[await] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_ziplatest(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 5, 2, interval=2) ys = stream.range(1, 5, 2, interval=2) | pipe.delay(1) zs = stream.ziplatest(xs, ys, default="▲") await assert_run(zs, [(0, "▲"), (0, 1), (2, 1), (2, 3), (4, 3)]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:171: AssertionError ______________________________ test_streamcontext ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: event_loop = @pytest.mark.asyncio async def test_streamcontext(event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | add_resource.pipe(1) async with streamcontext(xs) as streamer: it = iter(range(3)) > async for item in streamer: tests/test_core.py:16: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_never[aiter] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_never(assert_run, event_loop): xs = stream.never() | pipe.timeout(30.0) await assert_run(xs, [], asyncio.TimeoutError()) > assert event_loop.steps == [30.0] E assert [] == [30.0] E E Right contains one more item: 30.0 E Use -v to get more diff tests/test_create.py:55: AssertionError ______________________________ test_never[await] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_never(assert_run, event_loop): xs = stream.never() | pipe.timeout(30.0) await assert_run(xs, [], asyncio.TimeoutError()) > assert event_loop.steps == [30.0] E assert [] == [30.0] E E Right contains one more item: 30.0 E Use -v to get more diff tests/test_create.py:55: AssertionError ______________________________ test_range[aiter] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_range(assert_run, event_loop): xs = stream.range(3, 10, 2, interval=1.0) await assert_run(xs, [3, 5, 7, 9]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_create.py:71: AssertionError ______________________________ test_range[await] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_range(assert_run, event_loop): xs = stream.range(3, 10, 2, interval=1.0) await assert_run(xs, [3, 5, 7, 9]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_create.py:71: AssertionError __________________________ test_async_iterable[aiter] __________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_async_iterable(assert_run, event_loop): async def agen(): for x in range(2, 5): yield await asyncio.sleep(1.0, result=x**2) xs = stream.create.from_async_iterable(agen()) await assert_run(xs, [4, 9, 16]) > assert event_loop.steps == [1.0, 1.0, 1.0] E assert [] == [1.0, 1.0, 1.0] E E Right contains 3 more items, first extra item: 1.0 E Use -v to get more diff tests/test_create.py:99: AssertionError __________________________ test_async_iterable[await] __________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_async_iterable(assert_run, event_loop): async def agen(): for x in range(2, 5): yield await asyncio.sleep(1.0, result=x**2) xs = stream.create.from_async_iterable(agen()) await assert_run(xs, [4, 9, 16]) > assert event_loop.steps == [1.0, 1.0, 1.0] E assert [] == [1.0, 1.0, 1.0] E E Right contains 3 more items, first extra item: 1.0 E Use -v to get more diff tests/test_create.py:99: AssertionError ______________________________ test_action[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_action(assert_run, event_loop): with event_loop.assert_cleanup(): lst = [] xs = stream.range(3) | add_resource.pipe(1) | pipe.action(lst.append) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:17: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_action[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_action(assert_run, event_loop): with event_loop.assert_cleanup(): lst = [] xs = stream.range(3) | add_resource.pipe(1) | pipe.action(lst.append) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:17: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_print[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_print(assert_run, event_loop): with event_loop.assert_cleanup(): f = io.StringIO() xs = stream.range(3) | add_resource.pipe(1) | pipe.print(file=f) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:34: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_print[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_print(assert_run, event_loop): with event_loop.assert_cleanup(): f = io.StringIO() xs = stream.range(3) | add_resource.pipe(1) | pipe.print(file=f) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:34: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_take[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_take(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.count() | add_resource.pipe(1) | pipe.take(3) > await assert_run(xs, [0, 1, 2]) tests/test_select.py:15: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_take[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_take(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.count() | add_resource.pipe(1) | pipe.take(3) > await assert_run(xs, [0, 1, 2]) tests/test_select.py:15: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_takelast[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takelast(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.takelast(3) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:25: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:56: in takelast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_takelast[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takelast(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.takelast(3) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:25: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:56: in takelast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_skip[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skip(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.skip(8) > await assert_run(xs, [8, 9]) tests/test_select.py:31: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_skip[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skip(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.skip(8) > await assert_run(xs, [8, 9]) tests/test_select.py:31: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_skiplast[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skiplast(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(10) | add_resource.pipe(1) | pipe.skiplast(8) > await assert_run(xs, [0, 1]) tests/test_select.py:38: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:86: in skiplast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_skiplast[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skiplast(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(10) | add_resource.pipe(1) | pipe.skiplast(8) > await assert_run(xs, [0, 1]) tests/test_select.py:38: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:86: in skiplast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ___________________________ test_filterindex[aiter] ____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filterindex(assert_run, event_loop): filterindex = stream.select.filterindex xs = ( stream.range(10) | add_resource.pipe(1) | filterindex.pipe(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:53: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:107: in filterindex async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ___________________________ test_filterindex[await] ____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filterindex(assert_run, event_loop): filterindex = stream.select.filterindex xs = ( stream.range(10) | add_resource.pipe(1) | filterindex.pipe(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:53: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:107: in filterindex async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_slice[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_slice(assert_run, event_loop): slice = stream.select.slice with event_loop.assert_cleanup(): xs = stream.range(10, 20) | add_resource.pipe(1) | slice.pipe(2) > await assert_run(xs, [10, 11]) tests/test_select.py:62: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_slice[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_slice(assert_run, event_loop): slice = stream.select.slice with event_loop.assert_cleanup(): xs = stream.range(10, 20) | add_resource.pipe(1) | slice.pipe(2) > await assert_run(xs, [10, 11]) tests/test_select.py:62: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_item[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_item(assert_run, event_loop): item = stream.select.item with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | item.pipe(2) > await assert_run(xs, [2]) tests/test_select.py:89: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_item[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_item(assert_run, event_loop): item = stream.select.item with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | item.pipe(2) > await assert_run(xs, [2]) tests/test_select.py:89: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_getitem[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_getitem(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.getitem(2) > await assert_run(xs, [2]) tests/test_select.py:114: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_getitem[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_getitem(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.getitem(2) > await assert_run(xs, [2]) tests/test_select.py:114: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_filter[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filter(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.filter(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:150: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:203: in filter async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_filter[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filter(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.filter(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:150: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:203: in filter async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_until[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_until(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.until(lambda x: x == 3) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:166: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:227: in until async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_until[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_until(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.until(lambda x: x == 3) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:166: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:227: in until async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_takewhile[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takewhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.takewhile(lambda x: x < 4) ) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:184: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:252: in takewhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_takewhile[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takewhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.takewhile(lambda x: x < 4) ) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:184: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:252: in takewhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_dropwhile[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_dropwhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.dropwhile(lambda x: x < 7) ) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:202: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:275: in dropwhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_dropwhile[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_dropwhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.dropwhile(lambda x: x < 7) ) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:202: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:275: in dropwhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_timeout[aiter] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_timeout(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | pipe.timeout(5) await assert_run(xs, [0, 1, 2]) assert event_loop.steps == [] with event_loop.assert_cleanup(): xs = stream.range(3) + stream.never() ys = xs | pipe.timeout(1) await assert_run(ys, [0, 1, 2], asyncio.TimeoutError()) > assert event_loop.steps == [1] E assert [] == [1] E E Right contains one more item: 1 E Use -v to get more diff tests/test_time.py:22: AssertionError _____________________________ test_timeout[await] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_timeout(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | pipe.timeout(5) await assert_run(xs, [0, 1, 2]) assert event_loop.steps == [] with event_loop.assert_cleanup(): xs = stream.range(3) + stream.never() ys = xs | pipe.timeout(1) await assert_run(ys, [0, 1, 2], asyncio.TimeoutError()) > assert event_loop.steps == [1] E assert [] == [1] E E Right contains one more item: 1 E Use -v to get more diff tests/test_time.py:22: AssertionError _____________________________ test_starmap[aiter] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_starmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) ys = stream.range(5) zs = xs | pipe.zip(ys) | pipe.starmap(lambda x, y: x + y) expected = [x * 2 for x in range(5)] await assert_run(zs, expected) with event_loop.assert_cleanup(): xs = stream.range(1, 4) ys = stream.range(1, 4) zs = xs | pipe.zip(ys) | pipe.starmap(asyncio.sleep) await assert_run(zs, [1, 2, 3]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_transform.py:25: AssertionError _____________________________ test_starmap[await] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_starmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) ys = stream.range(5) zs = xs | pipe.zip(ys) | pipe.starmap(lambda x, y: x + y) expected = [x * 2 for x in range(5)] await assert_run(zs, expected) with event_loop.assert_cleanup(): xs = stream.range(1, 4) ys = stream.range(1, 4) zs = xs | pipe.zip(ys) | pipe.starmap(asyncio.sleep) await assert_run(zs, [1, 2, 3]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_transform.py:25: AssertionError ______________________________ test_cycle[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: > await asyncio.sleep(cleanup_time) aiostream/test_utils.py:32: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ delay = 1, result = None async def sleep(delay, result=None): """Coroutine that completes after a given time (in seconds).""" if delay <= 0: await __sleep0() return result if math.isnan(delay): raise ValueError("Invalid delay: NaN (not a number)") loop = events.get_running_loop() future = loop.create_future() h = loop.call_later(delay, futures._set_result_unless_cancelled, future, result) try: > return await future ^^^^^^^^^^^^ E asyncio.exceptions.CancelledError /usr/lib/python3.13/asyncio/tasks.py:718: CancelledError The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 25, in add_resource loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' During handling of the above exception, another exception occurred: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 32, in add_resource await asyncio.sleep(cleanup_time) File "/usr/lib/python3.13/asyncio/tasks.py", line 718, in sleep return await future ^^^^^^^^^^^^ asyncio.exceptions.CancelledError The above exception was the direct cause of the following exception: TimeoutError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_cycle(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.empty() | pipe.cycle() | pipe.timeout(1) await assert_run(xs, [], asyncio.TimeoutError()) with event_loop.assert_cleanup(): xs = stream.empty() | add_resource.pipe(1) | pipe.cycle() | pipe.timeout(1) > await assert_run(xs, [], asyncio.TimeoutError()) tests/test_transform.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/time.py:43: in timeout item = await asyncio.wait_for(anext(streamer), timeout) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ /usr/lib/python3.13/asyncio/tasks.py:507: in wait_for return await fut ^^^^^^^^^ aiostream/stream/transform.py:112: in cycle async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_cycle[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: > await asyncio.sleep(cleanup_time) aiostream/test_utils.py:32: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ delay = 1, result = None async def sleep(delay, result=None): """Coroutine that completes after a given time (in seconds).""" if delay <= 0: await __sleep0() return result if math.isnan(delay): raise ValueError("Invalid delay: NaN (not a number)") loop = events.get_running_loop() future = loop.create_future() h = loop.call_later(delay, futures._set_result_unless_cancelled, future, result) try: > return await future ^^^^^^^^^^^^ E asyncio.exceptions.CancelledError /usr/lib/python3.13/asyncio/tasks.py:718: CancelledError The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 25, in add_resource loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' During handling of the above exception, another exception occurred: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 32, in add_resource await asyncio.sleep(cleanup_time) File "/usr/lib/python3.13/asyncio/tasks.py", line 718, in sleep return await future ^^^^^^^^^^^^ asyncio.exceptions.CancelledError The above exception was the direct cause of the following exception: TimeoutError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_cycle(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.empty() | pipe.cycle() | pipe.timeout(1) await assert_run(xs, [], asyncio.TimeoutError()) with event_loop.assert_cleanup(): xs = stream.empty() | add_resource.pipe(1) | pipe.cycle() | pipe.timeout(1) > await assert_run(xs, [], asyncio.TimeoutError()) tests/test_transform.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/time.py:43: in timeout item = await asyncio.wait_for(anext(streamer), timeout) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ /usr/lib/python3.13/asyncio/tasks.py:507: in wait_for return await fut ^^^^^^^^^ aiostream/stream/transform.py:112: in cycle async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_chunks[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chunks(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2]]) with event_loop.assert_cleanup(): xs = stream.range(4, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3]]) with event_loop.assert_cleanup(): xs = stream.range(5, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3, 4]]) with event_loop.assert_cleanup(): xs = stream.count(interval=1) | add_resource.pipe(1) | pipe.chunks(3) > await assert_run(xs[:1], [[0, 1, 2]]) tests/test_transform.py:67: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: aiostream/stream/transform.py:126: in chunks async for first in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_chunks[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chunks(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2]]) with event_loop.assert_cleanup(): xs = stream.range(4, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3]]) with event_loop.assert_cleanup(): xs = stream.range(5, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3, 4]]) with event_loop.assert_cleanup(): xs = stream.count(interval=1) | add_resource.pipe(1) | pipe.chunks(3) > await assert_run(xs[:1], [[0, 1, 2]]) tests/test_transform.py:67: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: aiostream/stream/transform.py:126: in chunks async for first in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError =============================== warnings summary =============================== .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[aiter] .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[aiter] .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[await] .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[await] .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_raise_in_aitercontext .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_silence_exception_in_aitercontext .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_reraise_exception_in_aitercontext .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_stuck_in_aitercontext /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/aiter_utils.py:198: DeprecationWarning: the (type, exc, tb) signature of athrow() is deprecated, use the single-arg signature instead. await self._aiterator.athrow(typ, value, traceback) -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html ---------- coverage: platform linux, python 3.13.7-final-0 ----------- Name Stmts Miss Cover --------------------------------------------------- aiostream/__init__.py 4 0 100% aiostream/aiter_utils.py 106 14 87% aiostream/core.py 176 14 92% aiostream/manager.py 95 10 89% aiostream/pipe.py 36 0 100% aiostream/stream/__init__.py 8 0 100% aiostream/stream/advanced.py 64 2 97% aiostream/stream/aggregate.py 40 4 90% aiostream/stream/combine.py 93 4 96% aiostream/stream/create.py 81 3 96% aiostream/stream/misc.py 27 10 63% aiostream/stream/select.py 147 53 64% aiostream/stream/time.py 33 0 100% aiostream/stream/transform.py 52 3 94% aiostream/test_utils.py 106 24 77% --------------------------------------------------- TOTAL 1068 141 87% Coverage HTML written to dir htmlcov =========================== short test summary info ============================ FAILED tests/test_advanced.py::test_concatmap[aiter] - assert [] == [1, 1, 3,... FAILED tests/test_advanced.py::test_concatmap[await] - assert [] == [1, 1, 3,... FAILED tests/test_advanced.py::test_flatmap[aiter] - assert [] == [1, 1, 3, 1... FAILED tests/test_advanced.py::test_flatmap[await] - assert [] == [1, 1, 3, 1... FAILED tests/test_advanced.py::test_switchmap[aiter] - assert [] == [1, 1, 1,... FAILED tests/test_advanced.py::test_switchmap[await] - assert [] == [1, 1, 1,... FAILED tests/test_aggregate.py::test_aggregate[aiter] - AttributeError: '_Uni... FAILED tests/test_aggregate.py::test_aggregate[await] - AttributeError: '_Uni... FAILED tests/test_aggregate.py::test_reduce[aiter] - AttributeError: '_UnixSe... FAILED tests/test_aggregate.py::test_reduce[await] - AttributeError: '_UnixSe... FAILED tests/test_aggregate.py::test_list[aiter] - AttributeError: '_UnixSele... FAILED tests/test_aggregate.py::test_list[await] - AttributeError: '_UnixSele... FAILED tests/test_aiter.py::test_simple_aitercontext - assert [] == [1, 1, 1,... FAILED tests/test_combine.py::test_chain[aiter] - AttributeError: '_UnixSelec... FAILED tests/test_combine.py::test_chain[await] - AttributeError: '_UnixSelec... FAILED tests/test_combine.py::test_zip[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_combine.py::test_zip[await] - AttributeError: '_UnixSelecto... FAILED tests/test_combine.py::test_map[aiter] - assert [] == [1, 1, 1] FAILED tests/test_combine.py::test_map[await] - assert [] == [1, 1, 1] FAILED tests/test_combine.py::test_merge[aiter] - assert [] == [1, 1, 1, 1] FAILED tests/test_combine.py::test_merge[await] - assert [] == [1, 1, 1, 1] FAILED tests/test_combine.py::test_ziplatest[aiter] - assert [] == [1, 1, 1, 1] FAILED tests/test_combine.py::test_ziplatest[await] - assert [] == [1, 1, 1, 1] FAILED tests/test_core.py::test_streamcontext - AttributeError: '_UnixSelecto... FAILED tests/test_create.py::test_never[aiter] - assert [] == [30.0] FAILED tests/test_create.py::test_never[await] - assert [] == [30.0] FAILED tests/test_create.py::test_range[aiter] - assert [] == [1, 1, 1] FAILED tests/test_create.py::test_range[await] - assert [] == [1, 1, 1] FAILED tests/test_create.py::test_async_iterable[aiter] - assert [] == [1.0, ... FAILED tests/test_create.py::test_async_iterable[await] - assert [] == [1.0, ... FAILED tests/test_misc.py::test_action[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_misc.py::test_action[await] - AttributeError: '_UnixSelecto... FAILED tests/test_misc.py::test_print[aiter] - AttributeError: '_UnixSelector... FAILED tests/test_misc.py::test_print[await] - AttributeError: '_UnixSelector... FAILED tests/test_select.py::test_take[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_take[await] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_takelast[aiter] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_takelast[await] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_skip[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_skip[await] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_skiplast[aiter] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_skiplast[await] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_filterindex[aiter] - AttributeError: '_Unix... FAILED tests/test_select.py::test_filterindex[await] - AttributeError: '_Unix... FAILED tests/test_select.py::test_slice[aiter] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_slice[await] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_item[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_item[await] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_getitem[aiter] - AttributeError: '_UnixSele... FAILED tests/test_select.py::test_getitem[await] - AttributeError: '_UnixSele... FAILED tests/test_select.py::test_filter[aiter] - AttributeError: '_UnixSelec... FAILED tests/test_select.py::test_filter[await] - AttributeError: '_UnixSelec... FAILED tests/test_select.py::test_until[aiter] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_until[await] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_takewhile[aiter] - AttributeError: '_UnixSe... FAILED tests/test_select.py::test_takewhile[await] - AttributeError: '_UnixSe... FAILED tests/test_select.py::test_dropwhile[aiter] - AttributeError: '_UnixSe... FAILED tests/test_select.py::test_dropwhile[await] - AttributeError: '_UnixSe... FAILED tests/test_time.py::test_timeout[aiter] - assert [] == [1] FAILED tests/test_time.py::test_timeout[await] - assert [] == [1] FAILED tests/test_transform.py::test_starmap[aiter] - assert [] == [1, 1, 1] FAILED tests/test_transform.py::test_starmap[await] - assert [] == [1, 1, 1] FAILED tests/test_transform.py::test_cycle[aiter] - AttributeError: '_UnixSel... FAILED tests/test_transform.py::test_cycle[await] - AttributeError: '_UnixSel... FAILED tests/test_transform.py::test_chunks[aiter] - AttributeError: '_UnixSe... FAILED tests/test_transform.py::test_chunks[await] - AttributeError: '_UnixSe... ERROR tests/test_task_group.py::test_task_group_cleanup ======== 66 failed, 30 passed, 8 warnings, 1 error in 251.78s (0:04:11) ======== E: pybuild pybuild:389: test: plugin distutils failed with: exit code=1: cd /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build; python3.13 -m pytest tests 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: 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/2158390 and its subdirectories Starting cleanup. All cleanup done. Thu Oct 22 19:43:24 UTC 2026 - reproducible_build.sh stopped running as /tmp/jenkins-script-M40qWlhO, removing. /srv/reproducible-results/rbuild-debian/r-b-build.WT9ennms: total 16 drwxrwxr-x 2 jenkins jenkins 4096 Sep 19 13:20 b1 drwxrwxr-x 2 jenkins jenkins 4096 Sep 19 13:15 b2 -rw-rw-r-- 1 jenkins jenkins 2210 Sep 2 2024 python-aiostream_0.5.2-2.dsc -rw------- 1 jenkins jenkins 3373 Sep 19 13:15 rbuildlog.l9xCseI /srv/reproducible-results/rbuild-debian/r-b-build.WT9ennms/b1: total 172 -rw-r--r-- 1 jenkins jenkins 173253 Sep 19 13:20 build.log /srv/reproducible-results/rbuild-debian/r-b-build.WT9ennms/b2: total 0 Fri Sep 19 13:20:25 UTC 2025 I: Deleting $TMPDIR on ionos5-amd64.debian.net. I: pbuilder: network access will be disabled during build I: Current time: Thu Oct 22 07:38:07 -12 2026 I: pbuilder-time-stamp: 1792697887 I: Building the build Environment I: extracting base tarball [/var/cache/pbuilder/unstable-reproducible-base.tgz] I: copying local configuration W: --override-config is not set; not updating apt.conf Read the manpage for details. I: mounting /proc filesystem I: mounting /sys filesystem I: creating /{dev,run}/shm I: mounting /dev/pts filesystem I: redirecting /dev/ptmx to /dev/pts/ptmx I: policy-rc.d already exists I: Copying source file I: copying [python-aiostream_0.5.2-2.dsc] I: copying [./python-aiostream_0.5.2.orig.tar.xz] I: copying [./python-aiostream_0.5.2-2.debian.tar.xz] I: Extracting source dpkg-source: warning: cannot verify inline signature for ./python-aiostream_0.5.2-2.dsc: no acceptable signature found dpkg-source: info: extracting python-aiostream in python-aiostream-0.5.2 dpkg-source: info: unpacking python-aiostream_0.5.2.orig.tar.xz dpkg-source: info: unpacking python-aiostream_0.5.2-2.debian.tar.xz I: Not using root during the build. I: Installing the build-deps I: user script /srv/workspace/pbuilder/2158390/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='amd64' DEBIAN_FRONTEND='noninteractive' DEB_BUILD_OPTIONS='buildinfo=+all reproducible=+all parallel=42 ' DISTRIBUTION='unstable' HOME='/root' HOST_ARCH='amd64' IFS=' ' INVOCATION_ID='961b956feceb4cfc825395c9461eb693' LANG='C' LANGUAGE='en_US:en' LC_ALL='C' 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='2158390' PS1='# ' PS2='> ' 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.WT9ennms/pbuilderrc_4SgS --distribution unstable --hookdir /etc/pbuilder/first-build-hooks --debbuildopts -b --basetgz /var/cache/pbuilder/unstable-reproducible-base.tgz --buildresult /srv/reproducible-results/rbuild-debian/r-b-build.WT9ennms/b1 --logfile b1/build.log python-aiostream_0.5.2-2.dsc' SUDO_GID='110' SUDO_HOME='/var/lib/jenkins' SUDO_UID='105' SUDO_USER='jenkins' TERM='unknown' TZ='/usr/share/zoneinfo/Etc/GMT+12' USER='root' _='/usr/bin/systemd-run' http_proxy='http://213.165.73.152:3128' I: uname -a Linux ionos5-amd64 6.12.43+deb13-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.12.43-1 (2025-08-27) x86_64 GNU/Linux I: ls -l /bin lrwxrwxrwx 1 root root 7 Aug 10 2025 /bin -> usr/bin I: user script /srv/workspace/pbuilder/2158390/tmp/hooks/D02_print_environment finished -> Attempting to satisfy build-dependencies -> Creating pbuilder-satisfydepends-dummy package Package: pbuilder-satisfydepends-dummy Version: 0.invalid.0 Architecture: amd64 Maintainer: Debian Pbuilder Team Description: Dummy package to satisfy dependencies with aptitude - created by pbuilder This package was created automatically by pbuilder to satisfy the build-dependencies of the package being currently built. Depends: debhelper-compat (= 13), dh-sequence-python3, python3-all, python3-pytest, python3-pytest-asyncio, python3-pytest-cov, python3-pytest-runner, python3-typing-extensions dpkg-deb: building package 'pbuilder-satisfydepends-dummy' in '/tmp/satisfydepends-aptitude/pbuilder-satisfydepends-dummy.deb'. Selecting previously unselected package pbuilder-satisfydepends-dummy. (Reading database ... 19917 files and directories currently installed.) Preparing to unpack .../pbuilder-satisfydepends-dummy.deb ... Unpacking pbuilder-satisfydepends-dummy (0.invalid.0) ... dpkg: pbuilder-satisfydepends-dummy: dependency problems, but configuring anyway as you requested: pbuilder-satisfydepends-dummy depends on debhelper-compat (= 13); however: Package debhelper-compat is not installed. pbuilder-satisfydepends-dummy depends on dh-sequence-python3; however: Package dh-sequence-python3 is not installed. pbuilder-satisfydepends-dummy depends on python3-all; however: Package python3-all is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest; however: Package python3-pytest is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest-asyncio; however: Package python3-pytest-asyncio is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest-cov; however: Package python3-pytest-cov is not installed. pbuilder-satisfydepends-dummy depends on python3-pytest-runner; however: Package python3-pytest-runner is not installed. pbuilder-satisfydepends-dummy depends on python3-typing-extensions; however: Package python3-typing-extensions is not installed. Setting up pbuilder-satisfydepends-dummy (0.invalid.0) ... Reading package lists... Building dependency tree... Reading state information... Initializing package states... Writing extended state information... Building tag database... pbuilder-satisfydepends-dummy is already installed at the requested version (0.invalid.0) pbuilder-satisfydepends-dummy is already installed at the requested version (0.invalid.0) The following NEW packages will be installed: autoconf{a} automake{a} autopoint{a} autotools-dev{a} bsdextrautils{a} debhelper{a} dh-autoreconf{a} dh-python{a} dh-strip-nondeterminism{a} dwz{a} file{a} gettext{a} gettext-base{a} groff-base{a} intltool-debian{a} libarchive-zip-perl{a} libdebhelper-perl{a} libelf1t64{a} libexpat1{a} libffi8{a} libfile-stripnondeterminism-perl{a} libjs-jquery{a} libjs-jquery-hotkeys{a} libjs-jquery-isonscreen{a} libjs-jquery-metadata{a} libjs-jquery-tablesorter{a} libjs-jquery-throttle-debounce{a} libmagic-mgc{a} libmagic1t64{a} libpipeline1{a} libpython3-stdlib{a} libpython3.13-minimal{a} libpython3.13-stdlib{a} libreadline8t64{a} libtool{a} libuchardet0{a} libunistring5{a} libxml2-16{a} m4{a} man-db{a} media-types{a} netbase{a} po-debconf{a} python3{a} python3-all{a} python3-async-generator{a} python3-autocommand{a} python3-coverage{a} python3-inflect{a} python3-iniconfig{a} python3-jaraco.context{a} python3-jaraco.functools{a} python3-jaraco.text{a} python3-minimal{a} python3-more-itertools{a} python3-packaging{a} python3-pkg-resources{a} python3-pluggy{a} python3-pygments{a} python3-pytest{a} python3-pytest-asyncio{a} python3-pytest-cov{a} python3-pytest-runner{a} python3-setuptools{a} python3-typeguard{a} python3-typing-extensions{a} python3-zipp{a} python3.13{a} python3.13-minimal{a} readline-common{a} sensible-utils{a} tzdata{a} The following packages are RECOMMENDED but will NOT be installed: ca-certificates curl javascript-common libarchive-cpio-perl libltdl-dev libmail-sendmail-perl lynx wget 0 packages upgraded, 72 newly installed, 0 to remove and 0 not upgraded. Need to get 21.1 MB of archives. After unpacking 84.3 MB will be used. Writing extended state information... Get: 1 http://deb.debian.org/debian unstable/main amd64 libexpat1 amd64 2.7.2-1 [111 kB] Get: 2 http://deb.debian.org/debian unstable/main amd64 libpython3.13-minimal amd64 3.13.7-1 [864 kB] Get: 3 http://deb.debian.org/debian unstable/main amd64 python3.13-minimal amd64 3.13.7-1 [2216 kB] Get: 4 http://deb.debian.org/debian unstable/main amd64 python3-minimal amd64 3.13.7-1 [27.2 kB] Get: 5 http://deb.debian.org/debian unstable/main amd64 media-types all 13.0.0 [29.3 kB] Get: 6 http://deb.debian.org/debian unstable/main amd64 netbase all 6.5 [12.4 kB] Get: 7 http://deb.debian.org/debian unstable/main amd64 tzdata all 2025b-5 [260 kB] Get: 8 http://deb.debian.org/debian unstable/main amd64 libffi8 amd64 3.5.2-2 [25.5 kB] Get: 9 http://deb.debian.org/debian unstable/main amd64 readline-common all 8.3-3 [74.8 kB] Get: 10 http://deb.debian.org/debian unstable/main amd64 libreadline8t64 amd64 8.3-3 [191 kB] Get: 11 http://deb.debian.org/debian unstable/main amd64 libpython3.13-stdlib amd64 3.13.7-1 [1960 kB] Get: 12 http://deb.debian.org/debian unstable/main amd64 python3.13 amd64 3.13.7-1 [761 kB] Get: 13 http://deb.debian.org/debian unstable/main amd64 libpython3-stdlib amd64 3.13.7-1 [10.2 kB] Get: 14 http://deb.debian.org/debian unstable/main amd64 python3 amd64 3.13.7-1 [28.3 kB] Get: 15 http://deb.debian.org/debian unstable/main amd64 sensible-utils all 0.0.26 [27.0 kB] Get: 16 http://deb.debian.org/debian unstable/main amd64 libmagic-mgc amd64 1:5.46-5 [338 kB] Get: 17 http://deb.debian.org/debian unstable/main amd64 libmagic1t64 amd64 1:5.46-5 [109 kB] Get: 18 http://deb.debian.org/debian unstable/main amd64 file amd64 1:5.46-5 [43.6 kB] Get: 19 http://deb.debian.org/debian unstable/main amd64 gettext-base amd64 0.23.1-2+b1 [244 kB] Get: 20 http://deb.debian.org/debian unstable/main amd64 libuchardet0 amd64 0.0.8-2 [68.5 kB] Get: 21 http://deb.debian.org/debian unstable/main amd64 groff-base amd64 1.23.0-9 [1187 kB] Get: 22 http://deb.debian.org/debian unstable/main amd64 bsdextrautils amd64 2.41.1-3 [100 kB] Get: 23 http://deb.debian.org/debian unstable/main amd64 libpipeline1 amd64 1.5.8-1 [42.0 kB] Get: 24 http://deb.debian.org/debian unstable/main amd64 man-db amd64 2.13.1-1 [1469 kB] Get: 25 http://deb.debian.org/debian unstable/main amd64 m4 amd64 1.4.20-1 [324 kB] Get: 26 http://deb.debian.org/debian unstable/main amd64 autoconf all 2.72-3.1 [494 kB] Get: 27 http://deb.debian.org/debian unstable/main amd64 autotools-dev all 20240727.1 [60.2 kB] Get: 28 http://deb.debian.org/debian unstable/main amd64 automake all 1:1.17-4 [862 kB] Get: 29 http://deb.debian.org/debian unstable/main amd64 autopoint all 0.23.1-2 [770 kB] Get: 30 http://deb.debian.org/debian unstable/main amd64 libdebhelper-perl all 13.26 [91.8 kB] Get: 31 http://deb.debian.org/debian unstable/main amd64 libtool all 2.5.4-5 [540 kB] Get: 32 http://deb.debian.org/debian unstable/main amd64 dh-autoreconf all 21 [12.2 kB] Get: 33 http://deb.debian.org/debian unstable/main amd64 libarchive-zip-perl all 1.68-1 [104 kB] Get: 34 http://deb.debian.org/debian unstable/main amd64 libfile-stripnondeterminism-perl all 1.15.0-1 [19.9 kB] Get: 35 http://deb.debian.org/debian unstable/main amd64 dh-strip-nondeterminism all 1.15.0-1 [8812 B] Get: 36 http://deb.debian.org/debian unstable/main amd64 libelf1t64 amd64 0.193-3 [192 kB] Get: 37 http://deb.debian.org/debian unstable/main amd64 dwz amd64 0.16-2 [108 kB] Get: 38 http://deb.debian.org/debian unstable/main amd64 libunistring5 amd64 1.3-2 [477 kB] Get: 39 http://deb.debian.org/debian unstable/main amd64 libxml2-16 amd64 2.14.5+dfsg-0.2 [638 kB] Get: 40 http://deb.debian.org/debian unstable/main amd64 gettext amd64 0.23.1-2+b1 [1680 kB] Get: 41 http://deb.debian.org/debian unstable/main amd64 intltool-debian all 0.35.0+20060710.6 [22.9 kB] Get: 42 http://deb.debian.org/debian unstable/main amd64 po-debconf all 1.0.21+nmu1 [248 kB] Get: 43 http://deb.debian.org/debian unstable/main amd64 debhelper all 13.26 [939 kB] Get: 44 http://deb.debian.org/debian unstable/main amd64 dh-python all 6.20250414 [116 kB] Get: 45 http://deb.debian.org/debian unstable/main amd64 libjs-jquery all 3.7.1+dfsg+~3.5.33-1 [319 kB] Get: 46 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-hotkeys all 0.2.0-1 [12.6 kB] Get: 47 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-isonscreen all 1.2.0-1.1 [3196 B] Get: 48 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-metadata all 12-4 [6532 B] Get: 49 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-tablesorter all 1:2.31.3+dfsg1-4 [184 kB] Get: 50 http://deb.debian.org/debian unstable/main amd64 libjs-jquery-throttle-debounce all 1.1+dfsg.1-2 [12.2 kB] Get: 51 http://deb.debian.org/debian unstable/main amd64 python3-all amd64 3.13.7-1 [1048 B] Get: 52 http://deb.debian.org/debian unstable/main amd64 python3-async-generator all 1.10-4 [17.4 kB] Get: 53 http://deb.debian.org/debian unstable/main amd64 python3-autocommand all 2.2.2-3 [13.6 kB] Get: 54 http://deb.debian.org/debian unstable/main amd64 python3-coverage amd64 7.8.2+dfsg1-1 [182 kB] Get: 55 http://deb.debian.org/debian unstable/main amd64 python3-more-itertools all 10.8.0-1 [71.7 kB] Get: 56 http://deb.debian.org/debian unstable/main amd64 python3-typing-extensions all 4.15.0-1 [92.4 kB] Get: 57 http://deb.debian.org/debian unstable/main amd64 python3-typeguard all 4.4.4-1 [37.1 kB] Get: 58 http://deb.debian.org/debian unstable/main amd64 python3-inflect all 7.5.0-1 [33.0 kB] Get: 59 http://deb.debian.org/debian unstable/main amd64 python3-iniconfig all 1.1.1-2 [6396 B] Get: 60 http://deb.debian.org/debian unstable/main amd64 python3-jaraco.functools all 4.1.0-1 [12.0 kB] Get: 61 http://deb.debian.org/debian unstable/main amd64 python3-pkg-resources all 78.1.1-0.1 [224 kB] Get: 62 http://deb.debian.org/debian unstable/main amd64 python3-jaraco.text all 4.0.0-1 [11.4 kB] Get: 63 http://deb.debian.org/debian unstable/main amd64 python3-zipp all 3.23.0-1 [11.0 kB] Get: 64 http://deb.debian.org/debian unstable/main amd64 python3-setuptools all 78.1.1-0.1 [738 kB] Get: 65 http://deb.debian.org/debian unstable/main amd64 python3-jaraco.context all 6.0.1-1 [8276 B] Get: 66 http://deb.debian.org/debian unstable/main amd64 python3-packaging all 25.0-1 [56.6 kB] Get: 67 http://deb.debian.org/debian unstable/main amd64 python3-pluggy all 1.6.0-1 [27.1 kB] Get: 68 http://deb.debian.org/debian unstable/main amd64 python3-pygments all 2.18.0+dfsg-2 [836 kB] Get: 69 http://deb.debian.org/debian unstable/main amd64 python3-pytest all 8.4.2-1 [266 kB] Get: 70 http://deb.debian.org/debian unstable/main amd64 python3-pytest-asyncio all 1.1.0-2 [13.1 kB] Get: 71 http://deb.debian.org/debian unstable/main amd64 python3-pytest-cov all 5.0.0-1 [26.8 kB] Get: 72 http://deb.debian.org/debian unstable/main amd64 python3-pytest-runner all 2.11.1-4 [8432 B] Fetched 21.1 MB in 0s (120 MB/s) Preconfiguring packages ... Selecting previously unselected package libexpat1:amd64. (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 ... 19917 files and directories currently installed.) Preparing to unpack .../libexpat1_2.7.2-1_amd64.deb ... Unpacking libexpat1:amd64 (2.7.2-1) ... Selecting previously unselected package libpython3.13-minimal:amd64. Preparing to unpack .../libpython3.13-minimal_3.13.7-1_amd64.deb ... Unpacking libpython3.13-minimal:amd64 (3.13.7-1) ... Selecting previously unselected package python3.13-minimal. Preparing to unpack .../python3.13-minimal_3.13.7-1_amd64.deb ... Unpacking python3.13-minimal (3.13.7-1) ... Setting up libpython3.13-minimal:amd64 (3.13.7-1) ... Setting up libexpat1:amd64 (2.7.2-1) ... Setting up python3.13-minimal (3.13.7-1) ... Selecting previously unselected package python3-minimal. (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 ... 20251 files and directories currently installed.) Preparing to unpack .../0-python3-minimal_3.13.7-1_amd64.deb ... Unpacking python3-minimal (3.13.7-1) ... Selecting previously unselected package media-types. Preparing to unpack .../1-media-types_13.0.0_all.deb ... Unpacking media-types (13.0.0) ... Selecting previously unselected package netbase. Preparing to unpack .../2-netbase_6.5_all.deb ... Unpacking netbase (6.5) ... Selecting previously unselected package tzdata. Preparing to unpack .../3-tzdata_2025b-5_all.deb ... Unpacking tzdata (2025b-5) ... Selecting previously unselected package libffi8:amd64. Preparing to unpack .../4-libffi8_3.5.2-2_amd64.deb ... Unpacking libffi8:amd64 (3.5.2-2) ... Selecting previously unselected package readline-common. Preparing to unpack .../5-readline-common_8.3-3_all.deb ... Unpacking readline-common (8.3-3) ... Selecting previously unselected package libreadline8t64:amd64. Preparing to unpack .../6-libreadline8t64_8.3-3_amd64.deb ... Adding 'diversion of /lib/x86_64-linux-gnu/libhistory.so.8 to /lib/x86_64-linux-gnu/libhistory.so.8.usr-is-merged by libreadline8t64' Adding 'diversion of /lib/x86_64-linux-gnu/libhistory.so.8.2 to /lib/x86_64-linux-gnu/libhistory.so.8.2.usr-is-merged by libreadline8t64' Adding 'diversion of /lib/x86_64-linux-gnu/libreadline.so.8 to /lib/x86_64-linux-gnu/libreadline.so.8.usr-is-merged by libreadline8t64' Adding 'diversion of /lib/x86_64-linux-gnu/libreadline.so.8.2 to /lib/x86_64-linux-gnu/libreadline.so.8.2.usr-is-merged by libreadline8t64' Unpacking libreadline8t64:amd64 (8.3-3) ... Selecting previously unselected package libpython3.13-stdlib:amd64. Preparing to unpack .../7-libpython3.13-stdlib_3.13.7-1_amd64.deb ... Unpacking libpython3.13-stdlib:amd64 (3.13.7-1) ... Selecting previously unselected package python3.13. Preparing to unpack .../8-python3.13_3.13.7-1_amd64.deb ... Unpacking python3.13 (3.13.7-1) ... Selecting previously unselected package libpython3-stdlib:amd64. Preparing to unpack .../9-libpython3-stdlib_3.13.7-1_amd64.deb ... Unpacking libpython3-stdlib:amd64 (3.13.7-1) ... Setting up python3-minimal (3.13.7-1) ... Selecting previously unselected package python3. (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 ... 21266 files and directories currently installed.) Preparing to unpack .../00-python3_3.13.7-1_amd64.deb ... Unpacking python3 (3.13.7-1) ... Selecting previously unselected package sensible-utils. Preparing to unpack .../01-sensible-utils_0.0.26_all.deb ... Unpacking sensible-utils (0.0.26) ... Selecting previously unselected package libmagic-mgc. Preparing to unpack .../02-libmagic-mgc_1%3a5.46-5_amd64.deb ... Unpacking libmagic-mgc (1:5.46-5) ... Selecting previously unselected package libmagic1t64:amd64. Preparing to unpack .../03-libmagic1t64_1%3a5.46-5_amd64.deb ... Unpacking libmagic1t64:amd64 (1:5.46-5) ... Selecting previously unselected package file. Preparing to unpack .../04-file_1%3a5.46-5_amd64.deb ... Unpacking file (1:5.46-5) ... Selecting previously unselected package gettext-base. Preparing to unpack .../05-gettext-base_0.23.1-2+b1_amd64.deb ... Unpacking gettext-base (0.23.1-2+b1) ... Selecting previously unselected package libuchardet0:amd64. Preparing to unpack .../06-libuchardet0_0.0.8-2_amd64.deb ... Unpacking libuchardet0:amd64 (0.0.8-2) ... Selecting previously unselected package groff-base. Preparing to unpack .../07-groff-base_1.23.0-9_amd64.deb ... Unpacking groff-base (1.23.0-9) ... Selecting previously unselected package bsdextrautils. Preparing to unpack .../08-bsdextrautils_2.41.1-3_amd64.deb ... Unpacking bsdextrautils (2.41.1-3) ... Selecting previously unselected package libpipeline1:amd64. Preparing to unpack .../09-libpipeline1_1.5.8-1_amd64.deb ... Unpacking libpipeline1:amd64 (1.5.8-1) ... Selecting previously unselected package man-db. Preparing to unpack .../10-man-db_2.13.1-1_amd64.deb ... Unpacking man-db (2.13.1-1) ... Selecting previously unselected package m4. Preparing to unpack .../11-m4_1.4.20-1_amd64.deb ... Unpacking m4 (1.4.20-1) ... Selecting previously unselected package autoconf. Preparing to unpack .../12-autoconf_2.72-3.1_all.deb ... Unpacking autoconf (2.72-3.1) ... Selecting previously unselected package autotools-dev. Preparing to unpack .../13-autotools-dev_20240727.1_all.deb ... Unpacking autotools-dev (20240727.1) ... Selecting previously unselected package automake. Preparing to unpack .../14-automake_1%3a1.17-4_all.deb ... Unpacking automake (1:1.17-4) ... Selecting previously unselected package autopoint. Preparing to unpack .../15-autopoint_0.23.1-2_all.deb ... Unpacking autopoint (0.23.1-2) ... Selecting previously unselected package libdebhelper-perl. Preparing to unpack .../16-libdebhelper-perl_13.26_all.deb ... Unpacking libdebhelper-perl (13.26) ... Selecting previously unselected package libtool. Preparing to unpack .../17-libtool_2.5.4-5_all.deb ... Unpacking libtool (2.5.4-5) ... Selecting previously unselected package dh-autoreconf. Preparing to unpack .../18-dh-autoreconf_21_all.deb ... Unpacking dh-autoreconf (21) ... Selecting previously unselected package libarchive-zip-perl. Preparing to unpack .../19-libarchive-zip-perl_1.68-1_all.deb ... Unpacking libarchive-zip-perl (1.68-1) ... Selecting previously unselected package libfile-stripnondeterminism-perl. Preparing to unpack .../20-libfile-stripnondeterminism-perl_1.15.0-1_all.deb ... Unpacking libfile-stripnondeterminism-perl (1.15.0-1) ... Selecting previously unselected package dh-strip-nondeterminism. Preparing to unpack .../21-dh-strip-nondeterminism_1.15.0-1_all.deb ... Unpacking dh-strip-nondeterminism (1.15.0-1) ... Selecting previously unselected package libelf1t64:amd64. Preparing to unpack .../22-libelf1t64_0.193-3_amd64.deb ... Unpacking libelf1t64:amd64 (0.193-3) ... Selecting previously unselected package dwz. Preparing to unpack .../23-dwz_0.16-2_amd64.deb ... Unpacking dwz (0.16-2) ... Selecting previously unselected package libunistring5:amd64. Preparing to unpack .../24-libunistring5_1.3-2_amd64.deb ... Unpacking libunistring5:amd64 (1.3-2) ... Selecting previously unselected package libxml2-16:amd64. Preparing to unpack .../25-libxml2-16_2.14.5+dfsg-0.2_amd64.deb ... Unpacking libxml2-16:amd64 (2.14.5+dfsg-0.2) ... Selecting previously unselected package gettext. Preparing to unpack .../26-gettext_0.23.1-2+b1_amd64.deb ... Unpacking gettext (0.23.1-2+b1) ... Selecting previously unselected package intltool-debian. Preparing to unpack .../27-intltool-debian_0.35.0+20060710.6_all.deb ... Unpacking intltool-debian (0.35.0+20060710.6) ... Selecting previously unselected package po-debconf. Preparing to unpack .../28-po-debconf_1.0.21+nmu1_all.deb ... Unpacking po-debconf (1.0.21+nmu1) ... Selecting previously unselected package debhelper. Preparing to unpack .../29-debhelper_13.26_all.deb ... Unpacking debhelper (13.26) ... Selecting previously unselected package dh-python. Preparing to unpack .../30-dh-python_6.20250414_all.deb ... Unpacking dh-python (6.20250414) ... Selecting previously unselected package libjs-jquery. Preparing to unpack .../31-libjs-jquery_3.7.1+dfsg+~3.5.33-1_all.deb ... Unpacking libjs-jquery (3.7.1+dfsg+~3.5.33-1) ... Selecting previously unselected package libjs-jquery-hotkeys. Preparing to unpack .../32-libjs-jquery-hotkeys_0.2.0-1_all.deb ... Unpacking libjs-jquery-hotkeys (0.2.0-1) ... Selecting previously unselected package libjs-jquery-isonscreen. Preparing to unpack .../33-libjs-jquery-isonscreen_1.2.0-1.1_all.deb ... Unpacking libjs-jquery-isonscreen (1.2.0-1.1) ... Selecting previously unselected package libjs-jquery-metadata. Preparing to unpack .../34-libjs-jquery-metadata_12-4_all.deb ... Unpacking libjs-jquery-metadata (12-4) ... Selecting previously unselected package libjs-jquery-tablesorter. Preparing to unpack .../35-libjs-jquery-tablesorter_1%3a2.31.3+dfsg1-4_all.deb ... Unpacking libjs-jquery-tablesorter (1:2.31.3+dfsg1-4) ... Selecting previously unselected package libjs-jquery-throttle-debounce. Preparing to unpack .../36-libjs-jquery-throttle-debounce_1.1+dfsg.1-2_all.deb ... Unpacking libjs-jquery-throttle-debounce (1.1+dfsg.1-2) ... Selecting previously unselected package python3-all. Preparing to unpack .../37-python3-all_3.13.7-1_amd64.deb ... Unpacking python3-all (3.13.7-1) ... Selecting previously unselected package python3-async-generator. Preparing to unpack .../38-python3-async-generator_1.10-4_all.deb ... Unpacking python3-async-generator (1.10-4) ... Selecting previously unselected package python3-autocommand. Preparing to unpack .../39-python3-autocommand_2.2.2-3_all.deb ... Unpacking python3-autocommand (2.2.2-3) ... Selecting previously unselected package python3-coverage. Preparing to unpack .../40-python3-coverage_7.8.2+dfsg1-1_amd64.deb ... Unpacking python3-coverage (7.8.2+dfsg1-1) ... Selecting previously unselected package python3-more-itertools. Preparing to unpack .../41-python3-more-itertools_10.8.0-1_all.deb ... Unpacking python3-more-itertools (10.8.0-1) ... Selecting previously unselected package python3-typing-extensions. Preparing to unpack .../42-python3-typing-extensions_4.15.0-1_all.deb ... Unpacking python3-typing-extensions (4.15.0-1) ... Selecting previously unselected package python3-typeguard. Preparing to unpack .../43-python3-typeguard_4.4.4-1_all.deb ... Unpacking python3-typeguard (4.4.4-1) ... Selecting previously unselected package python3-inflect. Preparing to unpack .../44-python3-inflect_7.5.0-1_all.deb ... Unpacking python3-inflect (7.5.0-1) ... Selecting previously unselected package python3-iniconfig. Preparing to unpack .../45-python3-iniconfig_1.1.1-2_all.deb ... Unpacking python3-iniconfig (1.1.1-2) ... Selecting previously unselected package python3-jaraco.functools. Preparing to unpack .../46-python3-jaraco.functools_4.1.0-1_all.deb ... Unpacking python3-jaraco.functools (4.1.0-1) ... Selecting previously unselected package python3-pkg-resources. Preparing to unpack .../47-python3-pkg-resources_78.1.1-0.1_all.deb ... Unpacking python3-pkg-resources (78.1.1-0.1) ... Selecting previously unselected package python3-jaraco.text. Preparing to unpack .../48-python3-jaraco.text_4.0.0-1_all.deb ... Unpacking python3-jaraco.text (4.0.0-1) ... Selecting previously unselected package python3-zipp. Preparing to unpack .../49-python3-zipp_3.23.0-1_all.deb ... Unpacking python3-zipp (3.23.0-1) ... Selecting previously unselected package python3-setuptools. Preparing to unpack .../50-python3-setuptools_78.1.1-0.1_all.deb ... Unpacking python3-setuptools (78.1.1-0.1) ... Selecting previously unselected package python3-jaraco.context. Preparing to unpack .../51-python3-jaraco.context_6.0.1-1_all.deb ... Unpacking python3-jaraco.context (6.0.1-1) ... Selecting previously unselected package python3-packaging. Preparing to unpack .../52-python3-packaging_25.0-1_all.deb ... Unpacking python3-packaging (25.0-1) ... Selecting previously unselected package python3-pluggy. Preparing to unpack .../53-python3-pluggy_1.6.0-1_all.deb ... Unpacking python3-pluggy (1.6.0-1) ... Selecting previously unselected package python3-pygments. Preparing to unpack .../54-python3-pygments_2.18.0+dfsg-2_all.deb ... Unpacking python3-pygments (2.18.0+dfsg-2) ... Selecting previously unselected package python3-pytest. Preparing to unpack .../55-python3-pytest_8.4.2-1_all.deb ... Unpacking python3-pytest (8.4.2-1) ... Selecting previously unselected package python3-pytest-asyncio. Preparing to unpack .../56-python3-pytest-asyncio_1.1.0-2_all.deb ... Unpacking python3-pytest-asyncio (1.1.0-2) ... Selecting previously unselected package python3-pytest-cov. Preparing to unpack .../57-python3-pytest-cov_5.0.0-1_all.deb ... Unpacking python3-pytest-cov (5.0.0-1) ... Selecting previously unselected package python3-pytest-runner. Preparing to unpack .../58-python3-pytest-runner_2.11.1-4_all.deb ... Unpacking python3-pytest-runner (2.11.1-4) ... Setting up media-types (13.0.0) ... Setting up libpipeline1:amd64 (1.5.8-1) ... Setting up bsdextrautils (2.41.1-3) ... Setting up libmagic-mgc (1:5.46-5) ... Setting up libarchive-zip-perl (1.68-1) ... Setting up libxml2-16:amd64 (2.14.5+dfsg-0.2) ... Setting up libdebhelper-perl (13.26) ... Setting up libmagic1t64:amd64 (1:5.46-5) ... Setting up gettext-base (0.23.1-2+b1) ... Setting up m4 (1.4.20-1) ... Setting up file (1:5.46-5) ... Setting up libjs-jquery-throttle-debounce (1.1+dfsg.1-2) ... Setting up libelf1t64:amd64 (0.193-3) ... Setting up tzdata (2025b-5) ... Current default time zone: 'Etc/UTC' Local time is now: Thu Oct 22 19:38:38 UTC 2026. Universal Time is now: Thu Oct 22 19:38:38 UTC 2026. Run 'dpkg-reconfigure tzdata' if you wish to change it. Setting up autotools-dev (20240727.1) ... Setting up libunistring5:amd64 (1.3-2) ... Setting up autopoint (0.23.1-2) ... Setting up autoconf (2.72-3.1) ... Setting up libffi8:amd64 (3.5.2-2) ... Setting up dwz (0.16-2) ... Setting up sensible-utils (0.0.26) ... Setting up libuchardet0:amd64 (0.0.8-2) ... Setting up netbase (6.5) ... Setting up libjs-jquery (3.7.1+dfsg+~3.5.33-1) ... Setting up libjs-jquery-hotkeys (0.2.0-1) ... Setting up readline-common (8.3-3) ... Setting up automake (1:1.17-4) ... update-alternatives: using /usr/bin/automake-1.17 to provide /usr/bin/automake (automake) in auto mode Setting up libfile-stripnondeterminism-perl (1.15.0-1) ... Setting up gettext (0.23.1-2+b1) ... Setting up libtool (2.5.4-5) ... Setting up intltool-debian (0.35.0+20060710.6) ... Setting up dh-autoreconf (21) ... Setting up libjs-jquery-metadata (12-4) ... Setting up libjs-jquery-isonscreen (1.2.0-1.1) ... Setting up libreadline8t64:amd64 (8.3-3) ... Setting up dh-strip-nondeterminism (1.15.0-1) ... Setting up libjs-jquery-tablesorter (1:2.31.3+dfsg1-4) ... Setting up groff-base (1.23.0-9) ... Setting up libpython3.13-stdlib:amd64 (3.13.7-1) ... Setting up libpython3-stdlib:amd64 (3.13.7-1) ... Setting up python3.13 (3.13.7-1) ... Setting up po-debconf (1.0.21+nmu1) ... Setting up python3 (3.13.7-1) ... Setting up python3-zipp (3.23.0-1) ... Setting up python3-autocommand (2.2.2-3) ... Setting up man-db (2.13.1-1) ... Not building database; man-db/auto-update is not 'true'. Setting up python3-pygments (2.18.0+dfsg-2) ... Setting up python3-packaging (25.0-1) ... Setting up python3-typing-extensions (4.15.0-1) ... Setting up python3-pluggy (1.6.0-1) ... Setting up dh-python (6.20250414) ... Setting up python3-more-itertools (10.8.0-1) ... Setting up python3-iniconfig (1.1.1-2) ... Setting up python3-jaraco.functools (4.1.0-1) ... Setting up python3-async-generator (1.10-4) ... Setting up python3-jaraco.context (6.0.1-1) ... Setting up python3-pytest (8.4.2-1) ... Setting up python3-typeguard (4.4.4-1) ... Setting up python3-all (3.13.7-1) ... Setting up python3-coverage (7.8.2+dfsg1-1) ... Setting up debhelper (13.26) ... Setting up python3-pytest-cov (5.0.0-1) ... Setting up python3-inflect (7.5.0-1) ... Setting up python3-jaraco.text (4.0.0-1) ... Setting up python3-pytest-asyncio (1.1.0-2) ... Setting up python3-pkg-resources (78.1.1-0.1) ... Setting up python3-setuptools (78.1.1-0.1) ... Setting up python3-pytest-runner (2.11.1-4) ... Processing triggers for libc-bin (2.41-12) ... Reading package lists... Building dependency tree... Reading state information... Reading extended state information... Initializing package states... Writing extended state information... Building tag database... -> Finished parsing the build-deps I: Building the package I: Running cd /build/reproducible-path/python-aiostream-0.5.2/ && 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-aiostream_0.5.2-2_source.changes dpkg-buildpackage: info: source package python-aiostream dpkg-buildpackage: info: source version 0.5.2-2 dpkg-buildpackage: info: source distribution unstable dpkg-buildpackage: info: source changed by Alexandre Detiste dpkg-source --before-build . dpkg-buildpackage: info: host architecture amd64 dpkg-source: info: using options from python-aiostream-0.5.2/debian/source/options: --extend-diff-ignore=^[^/]+.egg-info/ debian/rules clean dh clean --buildsystem=pybuild dh_auto_clean -O--buildsystem=pybuild I: pybuild base:311: python3.13 setup.py clean /usr/lib/python3/dist-packages/setuptools/__init__.py:94: _DeprecatedInstaller: setuptools.installer and fetch_build_eggs are deprecated. !! ******************************************************************************** Requirements should be satisfied by a PEP 517 installer. If you are using pip, you can try `pip install --use-pep517`. ******************************************************************************** !! dist.fetch_build_eggs(dist.setup_requires) /usr/lib/python3/dist-packages/setuptools/_distutils/dist.py:289: UserWarning: Unknown distribution option: 'tests_require' warnings.warn(msg) running clean removing '/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build' (and everything under it) 'build/bdist.linux-x86_64' does not exist -- can't clean it 'build/scripts-3.13' does not exist -- can't clean it dh_autoreconf_clean -O--buildsystem=pybuild dh_clean -O--buildsystem=pybuild debian/rules binary dh binary --buildsystem=pybuild dh_update_autotools_config -O--buildsystem=pybuild dh_autoreconf -O--buildsystem=pybuild dh_auto_configure -O--buildsystem=pybuild I: pybuild base:311: python3.13 setup.py config /usr/lib/python3/dist-packages/setuptools/__init__.py:94: _DeprecatedInstaller: setuptools.installer and fetch_build_eggs are deprecated. !! ******************************************************************************** Requirements should be satisfied by a PEP 517 installer. If you are using pip, you can try `pip install --use-pep517`. ******************************************************************************** !! dist.fetch_build_eggs(dist.setup_requires) /usr/lib/python3/dist-packages/setuptools/_distutils/dist.py:289: UserWarning: Unknown distribution option: 'tests_require' warnings.warn(msg) running config dh_auto_build -O--buildsystem=pybuild I: pybuild base:311: /usr/bin/python3 setup.py build /usr/lib/python3/dist-packages/setuptools/__init__.py:94: _DeprecatedInstaller: setuptools.installer and fetch_build_eggs are deprecated. !! ******************************************************************************** Requirements should be satisfied by a PEP 517 installer. If you are using pip, you can try `pip install --use-pep517`. ******************************************************************************** !! dist.fetch_build_eggs(dist.setup_requires) /usr/lib/python3/dist-packages/setuptools/_distutils/dist.py:289: UserWarning: Unknown distribution option: 'tests_require' warnings.warn(msg) running build running build_py creating /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/manager.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/aiter_utils.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/__init__.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/pipe.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/core.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream copying aiostream/test_utils.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream creating /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/select.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/aggregate.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/transform.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/time.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/create.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/__init__.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/advanced.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/combine.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/stream/misc.py -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/stream copying aiostream/py.typed -> /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream dh_auto_test -O--buildsystem=pybuild I: pybuild base:311: cd /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build; python3.13 -m pytest tests ============================= test session starts ============================== platform linux -- Python 3.13.7, pytest-8.4.2, pluggy-1.6.0 rootdir: /build/reproducible-path/python-aiostream-0.5.2 configfile: setup.cfg plugins: typeguard-4.4.4, cov-5.0.0, asyncio-1.1.0 asyncio: mode=Mode.STRICT, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function collected 97 items tests/test_advanced.py FFFFFF [ 6%] tests/test_aggregate.py FFFFFF [ 12%] tests/test_aiter.py F....... [ 20%] tests/test_combine.py FFFFFFFFFF [ 30%] tests/test_core.py F.... [ 36%] tests/test_create.py ........FF..FF....FF.... [ 60%] tests/test_misc.py FFFF [ 64%] tests/test_pipe.py . [ 65%] tests/test_select.py FFFFFFFFFFFFFFFFFFFFFFFF [ 90%] tests/test_task_group.py E [ 91%] tests/test_time.py FF [ 93%] tests/test_transform.py FFFFFF [100%] ==================================== ERRORS ==================================== __________________ ERROR at setup of test_task_group_cleanup ___________________ file /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/tests/test_task_group.py, line 34 @pytest.mark.asyncio async def test_task_group_cleanup(event_loop): async with TaskGroup() as group: t1 = group.create_task(task1()) t2 = group.create_task(task2()) t3 = group.create_task(task3()) t4 = group.create_task(task4()) t5 = group.create_task(task5()) # Cancel task1 t1.cancel() with pytest.raises(asyncio.CancelledError): await t1 assert t1.cancelled() # Join task2 assert await t2 == 2 # Task 3 is finished assert t3.done() # Task 4 and 5 are not finished assert not t4.done() assert not t5.done() E fixture 'event_loop' not found > available fixtures: _class_scoped_runner, _function_scoped_runner, _module_scoped_runner, _package_scoped_runner, _session_scoped_runner, cache, capfd, capfdbinary, caplog, capsys, capsysbinary, capteesys, cov, doctest_namespace, event_loop_policy, monkeypatch, no_cover, pytestconfig, record_property, record_testsuite_property, record_xml_attribute, recwarn, tmp_path, tmp_path_factory, tmpdir, tmpdir_factory, unused_tcp_port, unused_tcp_port_factory, unused_udp_port, unused_udp_port_factory > use 'pytest --fixtures [testpath]' for help on them. /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/tests/test_task_group.py:34 =================================== FAILURES =================================== ____________________________ test_concatmap[aiter] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_concatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.concatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 1, 2, 3, 4, 5]) > assert event_loop.steps == [1, 1, 3, 5, 5] E assert [] == [1, 1, 3, 5, 5] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:17: AssertionError ____________________________ test_concatmap[await] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_concatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.concatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 1, 2, 3, 4, 5]) > assert event_loop.steps == [1, 1, 3, 5, 5] E assert [] == [1, 1, 3, 5, 5] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:17: AssertionError _____________________________ test_flatmap[aiter] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_flatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.flatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 2, 4, 1, 3, 5]) > assert event_loop.steps == [1, 1, 3, 1, 1] E assert [] == [1, 1, 3, 1, 1] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:66: AssertionError _____________________________ test_flatmap[await] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_flatmap(assert_run, event_loop): # Concurrent run with event_loop.assert_cleanup(): xs = stream.range(0, 6, 2, interval=1) ys = xs | pipe.flatmap(lambda x: stream.range(x, x + 2, interval=5)) await assert_run(ys, [0, 2, 4, 1, 3, 5]) > assert event_loop.steps == [1, 1, 3, 1, 1] E assert [] == [1, 1, 3, 1, 1] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:66: AssertionError ____________________________ test_switchmap[aiter] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_switchmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 30, 10, interval=3) ys = xs | pipe.switchmap(lambda x: stream.range(x, x + 5, interval=1)) await assert_run(ys, [0, 1, 2, 10, 11, 12, 20, 21, 22, 23, 24]) > assert event_loop.steps == [1, 1, 1, 1, 1, 1, 1, 1, 1, 1] E assert [] == [1, 1, 1, 1, 1, 1, ...] E E Right contains 10 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:93: AssertionError ____________________________ test_switchmap[await] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_switchmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 30, 10, interval=3) ys = xs | pipe.switchmap(lambda x: stream.range(x, x + 5, interval=1)) await assert_run(ys, [0, 1, 2, 10, 11, 12, 20, 21, 22, 23, 24]) > assert event_loop.steps == [1, 1, 1, 1, 1, 1, 1, 1, 1, 1] E assert [] == [1, 1, 1, 1, 1, 1, ...] E E Right contains 10 more items, first extra item: 1 E Use -v to get more diff tests/test_advanced.py:93: AssertionError ____________________________ test_aggregate[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_aggregate(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.accumulate() > await assert_run(xs, [0, 1, 3, 6, 10]) tests/test_aggregate.py:16: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_aggregate[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_aggregate(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.accumulate() > await assert_run(xs, [0, 1, 3, 6, 10]) tests/test_aggregate.py:16: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_reduce[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_reduce(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.reduce(min) > await assert_run(xs, [0]) tests/test_aggregate.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:56: in takelast async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_reduce[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_reduce(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.reduce(min) > await assert_run(xs, [0]) tests/test_aggregate.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:56: in takelast async for item in streamer: aiostream/stream/aggregate.py:37: in accumulate value = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_list[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_list(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | add_resource.pipe(1) | pipe.list() # The same list object is yielded at each step > await assert_run(xs, [[0, 1, 2], [0, 1, 2], [0, 1, 2], [0, 1, 2]]) tests/test_aggregate.py:59: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/aggregate.py:88: in list async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_list[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_list(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | add_resource.pipe(1) | pipe.list() # The same list object is yielded at each step > await assert_run(xs, [[0, 1, 2], [0, 1, 2], [0, 1, 2], [0, 1, 2]]) tests/test_aggregate.py:59: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/aggregate.py:88: in list async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ___________________________ test_simple_aitercontext ___________________________ event_loop = @pytest.mark.asyncio async def test_simple_aitercontext(event_loop): async with aitercontext(agen()) as safe_gen: # Cannot enter twice with pytest.raises(RuntimeError): async with safe_gen: pass it = iter(range(5)) async for item in safe_gen: assert item == next(it) > assert event_loop.steps == [1] * 5 E assert [] == [1, 1, 1, 1, 1] E E Right contains 5 more items, first extra item: 1 E Use -v to get more diff tests/test_aiter.py:68: AssertionError ______________________________ test_chain[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chain(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) + stream.range(5, 10) await assert_run(xs, list(range(10))) with event_loop.assert_cleanup(): xs = stream.range(10, 15) | add_resource.pipe(1) xs += stream.range(15, 20) | add_resource.pipe(1) > await assert_run(xs, list(range(10, 20))) tests/test_combine.py:20: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:47: in chain async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_chain[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chain(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) + stream.range(5, 10) await assert_run(xs, list(range(10))) with event_loop.assert_cleanup(): xs = stream.range(10, 15) | add_resource.pipe(1) xs += stream.range(15, 20) | add_resource.pipe(1) > await assert_run(xs, list(range(10, 20))) tests/test_combine.py:20: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:47: in chain async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_zip[aiter] ________________________________ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_zip(assert_run, event_loop): xs = stream.range(5) | add_resource.pipe(1.0) ys = xs | pipe.zip(xs, xs) expected = [(x,) * 3 for x in range(5)] > await assert_run(ys, expected) tests/test_combine.py:28: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:84: in zip items = await asyncio.gather(*coros) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_zip[await] ________________________________ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_zip(assert_run, event_loop): xs = stream.range(5) | add_resource.pipe(1.0) ys = xs | pipe.zip(xs, xs) expected = [(x,) * 3 for x in range(5)] > await assert_run(ys, expected) tests/test_combine.py:28: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:84: in zip items = await asyncio.gather(*coros) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1.0 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_map[aiter] ________________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_map(assert_run, event_loop): # Synchronous/simple with event_loop.assert_cleanup(): xs = stream.range(5) | pipe.map(lambda x: x**2) expected = [x**2 for x in range(5)] await assert_run(xs, expected) # Synchronous/multiple with event_loop.assert_cleanup(): xs = stream.range(5) ys = xs | pipe.map(lambda x, y: x + y, xs) expected = [x * 2 for x in range(5)] await assert_run(ys, expected) # Asynchronous/simple/concurrent with event_loop.assert_cleanup(): xs = stream.range(1, 4) | pipe.map(asyncio.sleep) expected = [None] * 3 await assert_run(xs, expected) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:51: AssertionError _______________________________ test_map[await] ________________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_map(assert_run, event_loop): # Synchronous/simple with event_loop.assert_cleanup(): xs = stream.range(5) | pipe.map(lambda x: x**2) expected = [x**2 for x in range(5)] await assert_run(xs, expected) # Synchronous/multiple with event_loop.assert_cleanup(): xs = stream.range(5) ys = xs | pipe.map(lambda x, y: x + y, xs) expected = [x * 2 for x in range(5)] await assert_run(ys, expected) # Asynchronous/simple/concurrent with event_loop.assert_cleanup(): xs = stream.range(1, 4) | pipe.map(asyncio.sleep) expected = [None] * 3 await assert_run(xs, expected) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:51: AssertionError ______________________________ test_merge[aiter] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_merge(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 5, 2, interval=2) | pipe.delay(1) ys = stream.range(0, 5, 2, interval=2) | pipe.merge(xs) await assert_run(ys, [0, 1, 2, 3, 4]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:119: AssertionError ______________________________ test_merge[await] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_merge(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 5, 2, interval=2) | pipe.delay(1) ys = stream.range(0, 5, 2, interval=2) | pipe.merge(xs) await assert_run(ys, [0, 1, 2, 3, 4]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:119: AssertionError ____________________________ test_ziplatest[aiter] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_ziplatest(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 5, 2, interval=2) ys = stream.range(1, 5, 2, interval=2) | pipe.delay(1) zs = stream.ziplatest(xs, ys, default="▲") await assert_run(zs, [(0, "▲"), (0, 1), (2, 1), (2, 3), (4, 3)]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:171: AssertionError ____________________________ test_ziplatest[await] _____________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_ziplatest(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(0, 5, 2, interval=2) ys = stream.range(1, 5, 2, interval=2) | pipe.delay(1) zs = stream.ziplatest(xs, ys, default="▲") await assert_run(zs, [(0, "▲"), (0, 1), (2, 1), (2, 3), (4, 3)]) > assert event_loop.steps == [1, 1, 1, 1] E assert [] == [1, 1, 1, 1] E E Right contains 4 more items, first extra item: 1 E Use -v to get more diff tests/test_combine.py:171: AssertionError ______________________________ test_streamcontext ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: event_loop = @pytest.mark.asyncio async def test_streamcontext(event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | add_resource.pipe(1) async with streamcontext(xs) as streamer: it = iter(range(3)) > async for item in streamer: tests/test_core.py:16: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_never[aiter] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_never(assert_run, event_loop): xs = stream.never() | pipe.timeout(30.0) await assert_run(xs, [], asyncio.TimeoutError()) > assert event_loop.steps == [30.0] E assert [] == [30.0] E E Right contains one more item: 30.0 E Use -v to get more diff tests/test_create.py:55: AssertionError ______________________________ test_never[await] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_never(assert_run, event_loop): xs = stream.never() | pipe.timeout(30.0) await assert_run(xs, [], asyncio.TimeoutError()) > assert event_loop.steps == [30.0] E assert [] == [30.0] E E Right contains one more item: 30.0 E Use -v to get more diff tests/test_create.py:55: AssertionError ______________________________ test_range[aiter] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_range(assert_run, event_loop): xs = stream.range(3, 10, 2, interval=1.0) await assert_run(xs, [3, 5, 7, 9]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_create.py:71: AssertionError ______________________________ test_range[await] _______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_range(assert_run, event_loop): xs = stream.range(3, 10, 2, interval=1.0) await assert_run(xs, [3, 5, 7, 9]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_create.py:71: AssertionError __________________________ test_async_iterable[aiter] __________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_async_iterable(assert_run, event_loop): async def agen(): for x in range(2, 5): yield await asyncio.sleep(1.0, result=x**2) xs = stream.create.from_async_iterable(agen()) await assert_run(xs, [4, 9, 16]) > assert event_loop.steps == [1.0, 1.0, 1.0] E assert [] == [1.0, 1.0, 1.0] E E Right contains 3 more items, first extra item: 1.0 E Use -v to get more diff tests/test_create.py:99: AssertionError __________________________ test_async_iterable[await] __________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_async_iterable(assert_run, event_loop): async def agen(): for x in range(2, 5): yield await asyncio.sleep(1.0, result=x**2) xs = stream.create.from_async_iterable(agen()) await assert_run(xs, [4, 9, 16]) > assert event_loop.steps == [1.0, 1.0, 1.0] E assert [] == [1.0, 1.0, 1.0] E E Right contains 3 more items, first extra item: 1.0 E Use -v to get more diff tests/test_create.py:99: AssertionError ______________________________ test_action[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_action(assert_run, event_loop): with event_loop.assert_cleanup(): lst = [] xs = stream.range(3) | add_resource.pipe(1) | pipe.action(lst.append) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:17: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_action[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_action(assert_run, event_loop): with event_loop.assert_cleanup(): lst = [] xs = stream.range(3) | add_resource.pipe(1) | pipe.action(lst.append) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:17: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_print[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_print(assert_run, event_loop): with event_loop.assert_cleanup(): f = io.StringIO() xs = stream.range(3) | add_resource.pipe(1) | pipe.print(file=f) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:34: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_print[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_print(assert_run, event_loop): with event_loop.assert_cleanup(): f = io.StringIO() xs = stream.range(3) | add_resource.pipe(1) | pipe.print(file=f) > await assert_run(xs, [0, 1, 2]) tests/test_misc.py:34: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/combine.py:128: in smap async for item in streamer: aiostream/stream/combine.py:70: in zip async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_take[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_take(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.count() | add_resource.pipe(1) | pipe.take(3) > await assert_run(xs, [0, 1, 2]) tests/test_select.py:15: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_take[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_take(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.count() | add_resource.pipe(1) | pipe.take(3) > await assert_run(xs, [0, 1, 2]) tests/test_select.py:15: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_takelast[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takelast(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.takelast(3) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:25: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:56: in takelast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_takelast[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takelast(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.takelast(3) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:25: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:56: in takelast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_skip[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skip(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.skip(8) > await assert_run(xs, [8, 9]) tests/test_select.py:31: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_skip[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skip(assert_run, event_loop): xs = stream.range(10) | add_resource.pipe(1) | pipe.skip(8) > await assert_run(xs, [8, 9]) tests/test_select.py:31: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_skiplast[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skiplast(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(10) | add_resource.pipe(1) | pipe.skiplast(8) > await assert_run(xs, [0, 1]) tests/test_select.py:38: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:86: in skiplast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_skiplast[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_skiplast(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(10) | add_resource.pipe(1) | pipe.skiplast(8) > await assert_run(xs, [0, 1]) tests/test_select.py:38: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:86: in skiplast async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ___________________________ test_filterindex[aiter] ____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filterindex(assert_run, event_loop): filterindex = stream.select.filterindex xs = ( stream.range(10) | add_resource.pipe(1) | filterindex.pipe(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:53: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:107: in filterindex async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ___________________________ test_filterindex[await] ____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filterindex(assert_run, event_loop): filterindex = stream.select.filterindex xs = ( stream.range(10) | add_resource.pipe(1) | filterindex.pipe(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:53: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:107: in filterindex async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_slice[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_slice(assert_run, event_loop): slice = stream.select.slice with event_loop.assert_cleanup(): xs = stream.range(10, 20) | add_resource.pipe(1) | slice.pipe(2) > await assert_run(xs, [10, 11]) tests/test_select.py:62: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_slice[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_slice(assert_run, event_loop): slice = stream.select.slice with event_loop.assert_cleanup(): xs = stream.range(10, 20) | add_resource.pipe(1) | slice.pipe(2) > await assert_run(xs, [10, 11]) tests/test_select.py:62: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_item[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_item(assert_run, event_loop): item = stream.select.item with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | item.pipe(2) > await assert_run(xs, [2]) tests/test_select.py:89: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _______________________________ test_item[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_item(assert_run, event_loop): item = stream.select.item with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | item.pipe(2) > await assert_run(xs, [2]) tests/test_select.py:89: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_getitem[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_getitem(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.getitem(2) > await assert_run(xs, [2]) tests/test_select.py:114: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_getitem[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_getitem(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) | add_resource.pipe(1) | pipe.getitem(2) > await assert_run(xs, [2]) tests/test_select.py:114: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:163: in item result = await anext(streamer) ^^^^^^^^^^^^^^^^^^^^^ aiostream/stream/select.py:70: in skip async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_filter[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filter(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.filter(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:150: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:203: in filter async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_filter[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_filter(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.filter(lambda x: x in [4, 7, 8]) ) > await assert_run(xs, [4, 7, 8]) tests/test_select.py:150: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:203: in filter async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_until[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_until(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.until(lambda x: x == 3) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:166: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:227: in until async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_until[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_until(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(1, 10) | add_resource.pipe(1) | pipe.until(lambda x: x == 3) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:166: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:227: in until async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_takewhile[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takewhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.takewhile(lambda x: x < 4) ) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:184: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:252: in takewhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_takewhile[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_takewhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.takewhile(lambda x: x < 4) ) > await assert_run(xs, [1, 2, 3]) tests/test_select.py:184: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:252: in takewhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_dropwhile[aiter] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_dropwhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.dropwhile(lambda x: x < 7) ) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:202: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:275: in dropwhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ____________________________ test_dropwhile[await] _____________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_dropwhile(assert_run, event_loop): with event_loop.assert_cleanup(): xs = ( stream.range(1, 10) | add_resource.pipe(1) | pipe.dropwhile(lambda x: x < 7) ) > await assert_run(xs, [7, 8, 9]) tests/test_select.py:202: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:275: in dropwhile async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError _____________________________ test_timeout[aiter] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_timeout(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | pipe.timeout(5) await assert_run(xs, [0, 1, 2]) assert event_loop.steps == [] with event_loop.assert_cleanup(): xs = stream.range(3) + stream.never() ys = xs | pipe.timeout(1) await assert_run(ys, [0, 1, 2], asyncio.TimeoutError()) > assert event_loop.steps == [1] E assert [] == [1] E E Right contains one more item: 1 E Use -v to get more diff tests/test_time.py:22: AssertionError _____________________________ test_timeout[await] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_timeout(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3) | pipe.timeout(5) await assert_run(xs, [0, 1, 2]) assert event_loop.steps == [] with event_loop.assert_cleanup(): xs = stream.range(3) + stream.never() ys = xs | pipe.timeout(1) await assert_run(ys, [0, 1, 2], asyncio.TimeoutError()) > assert event_loop.steps == [1] E assert [] == [1] E E Right contains one more item: 1 E Use -v to get more diff tests/test_time.py:22: AssertionError _____________________________ test_starmap[aiter] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_starmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) ys = stream.range(5) zs = xs | pipe.zip(ys) | pipe.starmap(lambda x, y: x + y) expected = [x * 2 for x in range(5)] await assert_run(zs, expected) with event_loop.assert_cleanup(): xs = stream.range(1, 4) ys = stream.range(1, 4) zs = xs | pipe.zip(ys) | pipe.starmap(asyncio.sleep) await assert_run(zs, [1, 2, 3]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_transform.py:25: AssertionError _____________________________ test_starmap[await] ______________________________ assert_run = event_loop = @pytest.mark.asyncio async def test_starmap(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(5) ys = stream.range(5) zs = xs | pipe.zip(ys) | pipe.starmap(lambda x, y: x + y) expected = [x * 2 for x in range(5)] await assert_run(zs, expected) with event_loop.assert_cleanup(): xs = stream.range(1, 4) ys = stream.range(1, 4) zs = xs | pipe.zip(ys) | pipe.starmap(asyncio.sleep) await assert_run(zs, [1, 2, 3]) > assert event_loop.steps == [1, 1, 1] E assert [] == [1, 1, 1] E E Right contains 3 more items, first extra item: 1 E Use -v to get more diff tests/test_transform.py:25: AssertionError ______________________________ test_cycle[aiter] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: > await asyncio.sleep(cleanup_time) aiostream/test_utils.py:32: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ delay = 1, result = None async def sleep(delay, result=None): """Coroutine that completes after a given time (in seconds).""" if delay <= 0: await __sleep0() return result if math.isnan(delay): raise ValueError("Invalid delay: NaN (not a number)") loop = events.get_running_loop() future = loop.create_future() h = loop.call_later(delay, futures._set_result_unless_cancelled, future, result) try: > return await future ^^^^^^^^^^^^ E asyncio.exceptions.CancelledError /usr/lib/python3.13/asyncio/tasks.py:718: CancelledError The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 25, in add_resource loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' During handling of the above exception, another exception occurred: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 32, in add_resource await asyncio.sleep(cleanup_time) File "/usr/lib/python3.13/asyncio/tasks.py", line 718, in sleep return await future ^^^^^^^^^^^^ asyncio.exceptions.CancelledError The above exception was the direct cause of the following exception: TimeoutError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_cycle(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.empty() | pipe.cycle() | pipe.timeout(1) await assert_run(xs, [], asyncio.TimeoutError()) with event_loop.assert_cleanup(): xs = stream.empty() | add_resource.pipe(1) | pipe.cycle() | pipe.timeout(1) > await assert_run(xs, [], asyncio.TimeoutError()) tests/test_transform.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/time.py:43: in timeout item = await asyncio.wait_for(anext(streamer), timeout) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ /usr/lib/python3.13/asyncio/tasks.py:507: in wait_for return await fut ^^^^^^^^^ aiostream/stream/transform.py:112: in cycle async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_cycle[await] _______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: > await asyncio.sleep(cleanup_time) aiostream/test_utils.py:32: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ delay = 1, result = None async def sleep(delay, result=None): """Coroutine that completes after a given time (in seconds).""" if delay <= 0: await __sleep0() return result if math.isnan(delay): raise ValueError("Invalid delay: NaN (not a number)") loop = events.get_running_loop() future = loop.create_future() h = loop.call_later(delay, futures._set_result_unless_cancelled, future, result) try: > return await future ^^^^^^^^^^^^ E asyncio.exceptions.CancelledError /usr/lib/python3.13/asyncio/tasks.py:718: CancelledError The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 25, in add_resource loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' During handling of the above exception, another exception occurred: Traceback (most recent call last): File "/build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/test_utils.py", line 32, in add_resource await asyncio.sleep(cleanup_time) File "/usr/lib/python3.13/asyncio/tasks.py", line 718, in sleep return await future ^^^^^^^^^^^^ asyncio.exceptions.CancelledError The above exception was the direct cause of the following exception: TimeoutError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_cycle(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.empty() | pipe.cycle() | pipe.timeout(1) await assert_run(xs, [], asyncio.TimeoutError()) with event_loop.assert_cleanup(): xs = stream.empty() | add_resource.pipe(1) | pipe.cycle() | pipe.timeout(1) > await assert_run(xs, [], asyncio.TimeoutError()) tests/test_transform.py:43: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/time.py:43: in timeout item = await asyncio.wait_for(anext(streamer), timeout) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ /usr/lib/python3.13/asyncio/tasks.py:507: in wait_for return await fut ^^^^^^^^^ aiostream/stream/transform.py:112: in cycle async for item in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_chunks[aiter] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chunks(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2]]) with event_loop.assert_cleanup(): xs = stream.range(4, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3]]) with event_loop.assert_cleanup(): xs = stream.range(5, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3, 4]]) with event_loop.assert_cleanup(): xs = stream.count(interval=1) | add_resource.pipe(1) | pipe.chunks(3) > await assert_run(xs[:1], [[0, 1, 2]]) tests/test_transform.py:67: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:55: in assert_aiter async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: aiostream/stream/transform.py:126: in chunks async for first in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError ______________________________ test_chunks[await] ______________________________ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() > loop.open_resources += 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:25: AttributeError During handling of the above exception, another exception occurred: assert_run = event_loop = @pytest.mark.asyncio async def test_chunks(assert_run, event_loop): with event_loop.assert_cleanup(): xs = stream.range(3, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2]]) with event_loop.assert_cleanup(): xs = stream.range(4, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3]]) with event_loop.assert_cleanup(): xs = stream.range(5, interval=1) | pipe.chunks(3) await assert_run(xs, [[0, 1, 2], [3, 4]]) with event_loop.assert_cleanup(): xs = stream.count(interval=1) | add_resource.pipe(1) | pipe.chunks(3) > await assert_run(xs[:1], [[0, 1, 2]]) tests/test_transform.py:67: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ aiostream/test_utils.py:73: in assert_await result = await source ^^^^^^^^^^^^ aiostream/core.py:65: in wait_stream async for item in streamer: aiostream/stream/select.py:39: in take async for i, item in streamer: aiostream/stream/transform.py:43: in enumerate async for item in streamer: aiostream/stream/transform.py:126: in chunks async for first in streamer: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ source = cleanup_time = 1 @pipable_operator async def add_resource(source, cleanup_time): """Simulate an open resource in a stream operator.""" try: loop = asyncio.get_event_loop() loop.open_resources += 1 loop.resources += 1 async with streamcontext(source) as streamer: async for item in streamer: yield item finally: try: await asyncio.sleep(cleanup_time) finally: > loop.open_resources -= 1 ^^^^^^^^^^^^^^^^^^^ E AttributeError: '_UnixSelectorEventLoop' object has no attribute 'open_resources' aiostream/test_utils.py:34: AttributeError =============================== warnings summary =============================== .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[aiter] .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[aiter] .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[await] .pybuild/cpython3_3.13/build/tests/test_advanced.py::test_switchmap[await] .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_raise_in_aitercontext .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_silence_exception_in_aitercontext .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_reraise_exception_in_aitercontext .pybuild/cpython3_3.13/build/tests/test_aiter.py::test_stuck_in_aitercontext /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build/aiostream/aiter_utils.py:198: DeprecationWarning: the (type, exc, tb) signature of athrow() is deprecated, use the single-arg signature instead. await self._aiterator.athrow(typ, value, traceback) -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html ---------- coverage: platform linux, python 3.13.7-final-0 ----------- Name Stmts Miss Cover --------------------------------------------------- aiostream/__init__.py 4 0 100% aiostream/aiter_utils.py 106 14 87% aiostream/core.py 176 14 92% aiostream/manager.py 95 10 89% aiostream/pipe.py 36 0 100% aiostream/stream/__init__.py 8 0 100% aiostream/stream/advanced.py 64 2 97% aiostream/stream/aggregate.py 40 4 90% aiostream/stream/combine.py 93 4 96% aiostream/stream/create.py 81 3 96% aiostream/stream/misc.py 27 10 63% aiostream/stream/select.py 147 53 64% aiostream/stream/time.py 33 0 100% aiostream/stream/transform.py 52 3 94% aiostream/test_utils.py 106 24 77% --------------------------------------------------- TOTAL 1068 141 87% Coverage HTML written to dir htmlcov =========================== short test summary info ============================ FAILED tests/test_advanced.py::test_concatmap[aiter] - assert [] == [1, 1, 3,... FAILED tests/test_advanced.py::test_concatmap[await] - assert [] == [1, 1, 3,... FAILED tests/test_advanced.py::test_flatmap[aiter] - assert [] == [1, 1, 3, 1... FAILED tests/test_advanced.py::test_flatmap[await] - assert [] == [1, 1, 3, 1... FAILED tests/test_advanced.py::test_switchmap[aiter] - assert [] == [1, 1, 1,... FAILED tests/test_advanced.py::test_switchmap[await] - assert [] == [1, 1, 1,... FAILED tests/test_aggregate.py::test_aggregate[aiter] - AttributeError: '_Uni... FAILED tests/test_aggregate.py::test_aggregate[await] - AttributeError: '_Uni... FAILED tests/test_aggregate.py::test_reduce[aiter] - AttributeError: '_UnixSe... FAILED tests/test_aggregate.py::test_reduce[await] - AttributeError: '_UnixSe... FAILED tests/test_aggregate.py::test_list[aiter] - AttributeError: '_UnixSele... FAILED tests/test_aggregate.py::test_list[await] - AttributeError: '_UnixSele... FAILED tests/test_aiter.py::test_simple_aitercontext - assert [] == [1, 1, 1,... FAILED tests/test_combine.py::test_chain[aiter] - AttributeError: '_UnixSelec... FAILED tests/test_combine.py::test_chain[await] - AttributeError: '_UnixSelec... FAILED tests/test_combine.py::test_zip[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_combine.py::test_zip[await] - AttributeError: '_UnixSelecto... FAILED tests/test_combine.py::test_map[aiter] - assert [] == [1, 1, 1] FAILED tests/test_combine.py::test_map[await] - assert [] == [1, 1, 1] FAILED tests/test_combine.py::test_merge[aiter] - assert [] == [1, 1, 1, 1] FAILED tests/test_combine.py::test_merge[await] - assert [] == [1, 1, 1, 1] FAILED tests/test_combine.py::test_ziplatest[aiter] - assert [] == [1, 1, 1, 1] FAILED tests/test_combine.py::test_ziplatest[await] - assert [] == [1, 1, 1, 1] FAILED tests/test_core.py::test_streamcontext - AttributeError: '_UnixSelecto... FAILED tests/test_create.py::test_never[aiter] - assert [] == [30.0] FAILED tests/test_create.py::test_never[await] - assert [] == [30.0] FAILED tests/test_create.py::test_range[aiter] - assert [] == [1, 1, 1] FAILED tests/test_create.py::test_range[await] - assert [] == [1, 1, 1] FAILED tests/test_create.py::test_async_iterable[aiter] - assert [] == [1.0, ... FAILED tests/test_create.py::test_async_iterable[await] - assert [] == [1.0, ... FAILED tests/test_misc.py::test_action[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_misc.py::test_action[await] - AttributeError: '_UnixSelecto... FAILED tests/test_misc.py::test_print[aiter] - AttributeError: '_UnixSelector... FAILED tests/test_misc.py::test_print[await] - AttributeError: '_UnixSelector... FAILED tests/test_select.py::test_take[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_take[await] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_takelast[aiter] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_takelast[await] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_skip[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_skip[await] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_skiplast[aiter] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_skiplast[await] - AttributeError: '_UnixSel... FAILED tests/test_select.py::test_filterindex[aiter] - AttributeError: '_Unix... FAILED tests/test_select.py::test_filterindex[await] - AttributeError: '_Unix... FAILED tests/test_select.py::test_slice[aiter] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_slice[await] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_item[aiter] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_item[await] - AttributeError: '_UnixSelecto... FAILED tests/test_select.py::test_getitem[aiter] - AttributeError: '_UnixSele... FAILED tests/test_select.py::test_getitem[await] - AttributeError: '_UnixSele... FAILED tests/test_select.py::test_filter[aiter] - AttributeError: '_UnixSelec... FAILED tests/test_select.py::test_filter[await] - AttributeError: '_UnixSelec... FAILED tests/test_select.py::test_until[aiter] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_until[await] - AttributeError: '_UnixSelect... FAILED tests/test_select.py::test_takewhile[aiter] - AttributeError: '_UnixSe... FAILED tests/test_select.py::test_takewhile[await] - AttributeError: '_UnixSe... FAILED tests/test_select.py::test_dropwhile[aiter] - AttributeError: '_UnixSe... FAILED tests/test_select.py::test_dropwhile[await] - AttributeError: '_UnixSe... FAILED tests/test_time.py::test_timeout[aiter] - assert [] == [1] FAILED tests/test_time.py::test_timeout[await] - assert [] == [1] FAILED tests/test_transform.py::test_starmap[aiter] - assert [] == [1, 1, 1] FAILED tests/test_transform.py::test_starmap[await] - assert [] == [1, 1, 1] FAILED tests/test_transform.py::test_cycle[aiter] - AttributeError: '_UnixSel... FAILED tests/test_transform.py::test_cycle[await] - AttributeError: '_UnixSel... FAILED tests/test_transform.py::test_chunks[aiter] - AttributeError: '_UnixSe... FAILED tests/test_transform.py::test_chunks[await] - AttributeError: '_UnixSe... ERROR tests/test_task_group.py::test_task_group_cleanup ======== 66 failed, 30 passed, 8 warnings, 1 error in 251.78s (0:04:11) ======== E: pybuild pybuild:389: test: plugin distutils failed with: exit code=1: cd /build/reproducible-path/python-aiostream-0.5.2/.pybuild/cpython3_3.13/build; python3.13 -m pytest tests 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: 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/2158390 and its subdirectories python-aiostream failed to build from source. removed '/var/lib/jenkins/userContent/reproducible/debian/rbuild/unstable/amd64/python-aiostream_0.5.2-2.rbuild.log' removed '/var/lib/jenkins/userContent/reproducible/debian/rbuild/unstable/amd64/python-aiostream_0.5.2-2.rbuild.log.gz' removed '/var/lib/jenkins/userContent/reproducible/debian/logs/unstable/amd64/python-aiostream_0.5.2-2.build1.log.gz' Fri Sep 19 13:20:25 UTC 2025 W: No second build log, what happened? Compressing the 1st log... b1/build.log: 91.7% -- replaced with stdout INSERT 0 1 INSERT 0 1 DELETE 1 [2025-09-19 13:20:26] INFO: Starting at 2025-09-19 13:20:26.586546 [2025-09-19 13:20:26] INFO: Generating the pages of 1 package(s) [2025-09-19 13:20:26] CRITICAL: https://tests.reproducible-builds.org/debian/unstable/amd64/python-aiostream didn't produce a buildlog, even though it has been built. [2025-09-19 13:20:26] INFO: Finished at 2025-09-19 13:20:26.833575, took: 0:00:00.247035 Fri Sep 19 13:20:26 UTC 2025 - successfully updated the database and updated https://tests.reproducible-builds.org/debian/rb-pkg/unstable/amd64/python-aiostream.html Starting cleanup. /var/lib/jenkins/userContent/reproducible/debian/rbuild/unstable/amd64/python-aiostream_0.5.2-2.rbuild.log: 90.9% -- replaced with /var/lib/jenkins/userContent/reproducible/debian/rbuild/unstable/amd64/python-aiostream_0.5.2-2.rbuild.log.gz [2025-09-19 13:20:27] INFO: Starting at 2025-09-19 13:20:27.197902 [2025-09-19 13:20:27] INFO: Generating the pages of 1 package(s) [2025-09-19 13:20:27] ERROR: Either /var/lib/jenkins/userContent/reproducible/debian/logs/unstable/amd64/python-aiostream_0.5.2-2.build2.log.gz or /var/lib/jenkins/userContent/reproducible/debian/logdiffs/unstable/amd64/python-aiostream_0.5.2-2.diff.gz is missing [2025-09-19 13:20:27] INFO: Finished at 2025-09-19 13:20:27.425639, took: 0:00:00.227740 All cleanup done. Fri Sep 19 13:20:27 UTC 2025 - total duration: 0h 5m 33s. Fri Sep 19 13:20:27 UTC 2025 - reproducible_build.sh stopped running as /tmp/jenkins-script-eb9jKrxV, removing. Finished with result: success Main processes terminated with: code=exited, status=0/SUCCESS Service runtime: 5min 33.656s CPU time consumed: 2.557s Memory peak: 38.5M (swap: 0B)