<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kombu.git/kombu/asynchronous/hub.py, branch py310</title>
<subtitle>github.com: celery/kombu.git
</subtitle>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/'/>
<entry>
<title>hub: tick delay fix (#1587)</title>
<updated>2022-08-24T08:32:35+00:00</updated>
<author>
<name>Shahar Lev</name>
<email>shahar_lev@hotmail.com</email>
</author>
<published>2022-08-24T08:32:35+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=717ad3ddc98d83a7b9e2cb7054bb92a0cd6c8d53'/>
<id>717ad3ddc98d83a7b9e2cb7054bb92a0cd6c8d53</id>
<content type='text'>
* hub: tick delay fix

todo and timer callbacks can perform actions that
require a tick callback to be executed right away
without polling.

the current order can cause issues
when using single worker with no prefetch (acks late).

related issue in celery:
https://github.com/celery/celery/issues/7718

* add unit test for hub delay fix

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Co-authored-by: pre-commit-ci[bot] &lt;66853113+pre-commit-ci[bot]@users.noreply.github.com&gt;</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* hub: tick delay fix

todo and timer callbacks can perform actions that
require a tick callback to be executed right away
without polling.

the current order can cause issues
when using single worker with no prefetch (acks late).

related issue in celery:
https://github.com/celery/celery/issues/7718

* add unit test for hub delay fix

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Co-authored-by: pre-commit-ci[bot] &lt;66853113+pre-commit-ci[bot]@users.noreply.github.com&gt;</pre>
</div>
</content>
</entry>
<entry>
<title>Bump pyupgrade version and add __future__.annotations import</title>
<updated>2022-04-15T08:16:57+00:00</updated>
<author>
<name>Marcelo Trylesinski</name>
<email>marcelotryle@gmail.com</email>
</author>
<published>2022-04-14T11:02:52+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=7516daf7a774dd9671d16c475c6ac266de977a0a'/>
<id>7516daf7a774dd9671d16c475c6ac266de977a0a</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Annotate init files (#1527)</title>
<updated>2022-04-14T05:10:01+00:00</updated>
<author>
<name>Marcelo Trylesinski</name>
<email>marcelotryle@gmail.com</email>
</author>
<published>2022-04-14T05:10:01+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=a93099b671f83ed5a3f723198cb821041ca5e13e'/>
<id>a93099b671f83ed5a3f723198cb821041ca5e13e</id>
<content type='text'>
* Annotate init files

* Fix fmatch_best annotation</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Annotate init files

* Fix fmatch_best annotation</pre>
</div>
</content>
</entry>
<entry>
<title>Protect set of ready tasks by lock to avoid concurrent updates. (#1489)</title>
<updated>2022-03-24T14:49:17+00:00</updated>
<author>
<name>Oliver Nemček</name>
<email>oliver.nemcek@gmail.com</email>
</author>
<published>2022-03-24T14:49:17+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=aab2588c4ab2f8fd67c6d1c6be3243504b028504'/>
<id>aab2588c4ab2f8fd67c6d1c6be3243504b028504</id>
<content type='text'>
When there is no locking then there is a possibility that multiple threads
manipulate with the same object at the same time.
The issue is manifested as:
```
RuntimeError: Set changed size during iteration
```

See: https://github.com/celery/celery/issues/7162</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
When there is no locking then there is a possibility that multiple threads
manipulate with the same object at the same time.
The issue is manifested as:
```
RuntimeError: Set changed size during iteration
```

See: https://github.com/celery/celery/issues/7162</pre>
</div>
</content>
</entry>
<entry>
<title>enable pre-commit (#1355)</title>
<updated>2021-07-20T13:07:49+00:00</updated>
<author>
<name>Thomas Grainger</name>
<email>tagrain@gmail.com</email>
</author>
<published>2021-07-20T13:07:49+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=241b5dcff8a7c8ad411e1b325d59e47acfa9e1ed'/>
<id>241b5dcff8a7c8ad411e1b325d59e47acfa9e1ed</id>
<content type='text'>
* enable pre-commit

* use extend-ignore for flake8

* manual flake8 fixes

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* Update kombu/__init__.py

Co-authored-by: pre-commit-ci[bot] &lt;66853113+pre-commit-ci[bot]@users.noreply.github.com&gt;</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* enable pre-commit

* use extend-ignore for flake8

* manual flake8 fixes

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* Update kombu/__init__.py

Co-authored-by: pre-commit-ci[bot] &lt;66853113+pre-commit-ci[bot]@users.noreply.github.com&gt;</pre>
</div>
</content>
</entry>
<entry>
<title>Remove five usage from kombu/asynchronous.</title>
<updated>2020-07-23T13:29:10+00:00</updated>
<author>
<name>Omer Katz</name>
<email>omer.drow@gmail.com</email>
</author>
<published>2020-07-23T13:29:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=ff48da68b7fd40d2d835bcc95ddd798269e92562'/>
<id>ff48da68b7fd40d2d835bcc95ddd798269e92562</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>pyupgrade</title>
<updated>2020-07-13T13:58:06+00:00</updated>
<author>
<name>Omer Katz</name>
<email>omer.drow@gmail.com</email>
</author>
<published>2020-07-13T13:58:06+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=7a6e7cc45b9afe799770313a66c4211d1986ff30'/>
<id>7a6e7cc45b9afe799770313a66c4211d1986ff30</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>reset ready before execute callback (#1126)</title>
<updated>2019-12-01T22:11:15+00:00</updated>
<author>
<name>Smite Chow</name>
<email>xiaopengyou@live.com</email>
</author>
<published>2019-12-01T22:11:15+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=de8d8cf8c1f6cd6da8b5d0b4cd66130b1f129e21'/>
<id>de8d8cf8c1f6cd6da8b5d0b4cd66130b1f129e21</id>
<content type='text'>
* reset ready before execute callback

* add test to cover hub._ready reset to empty
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* reset ready before execute callback

* add test to cover hub._ready reset to empty
</pre>
</div>
</content>
</entry>
<entry>
<title>Avoid raising StopIterator in generators. (#972)</title>
<updated>2019-01-03T20:02:32+00:00</updated>
<author>
<name>Omer Katz</name>
<email>omer.drow@gmail.com</email>
</author>
<published>2019-01-03T20:02:32+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=3e3886b245125237ec3420e9c9ae13e376a98b5f'/>
<id>3e3886b245125237ec3420e9c9ae13e376a98b5f</id>
<content type='text'>
According to [PEP-479](https://www.python.org/dev/peps/pep-0479/) StopIteration should not be used any more to indicate the termination of a generator.
Starting from Python 3.7 this behaviour is always enforced and a RuntimeError is raised instead.
We now return instead of raising StopIteration.</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
According to [PEP-479](https://www.python.org/dev/peps/pep-0479/) StopIteration should not be used any more to indicate the termination of a generator.
Starting from Python 3.7 this behaviour is always enforced and a RuntimeError is raised instead.
We now return instead of raising StopIteration.</pre>
</div>
</content>
</entry>
<entry>
<title>Used a tuple instead of a list to define __all__. (#945)</title>
<updated>2018-11-12T14:05:58+00:00</updated>
<author>
<name>Mads Jensen</name>
<email>mje@inducks.org</email>
</author>
<published>2018-11-12T14:05:58+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kombu.git/commit/?id=5e6fcca8d4aeb4217a3ab27cd0341430b1e277f6'/>
<id>5e6fcca8d4aeb4217a3ab27cd0341430b1e277f6</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
