<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/rq.git/docs, branch master</title>
<subtitle>github.com: nvie/rq.git
</subtitle>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/'/>
<entry>
<title>Update cli.py to support custom loggers (#1906)</title>
<updated>2023-05-18T00:04:57+00:00</updated>
<author>
<name>juur</name>
<email>juur@users.noreply.github.com</email>
</author>
<published>2023-05-18T00:04:57+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=107221fd9ef1db5eca0d55459a318ad65dd253f5'/>
<id>107221fd9ef1db5eca0d55459a318ad65dd253f5</id>
<content type='text'>
* Update cli.py to support custom loggers

Allows a config.py file (via rq worker --config) to support things like this for logfmt logging:

DICT_CONFIG = {
        "version": 1,
        "formatters": {"logfmt": {
            "()": "logfmter.Logfmter",
            "keys": ["level","when","pid"],
            "mapping": {"level":"levelname","when":"asctime","pid":"process"},
            "datefmt": "%Y-%m-%dT%H:%M:%S%z"
            }},
        "handlers": {"console": {"class": "logging.StreamHandler","formatter": "logfmt" }},
        "loggers": {
            "root": {"handlers":["console"], "level": "INFO"},
            "rq":   {"handlers":["console"], "level": "INFO", "propagate": False},
            }
        }

* added simple test and documentation for DICT_CONFIG

* further attempt to get testing right for dictConfig

* move import to correct location

* fix

* remove meaningless options.get() usage

* linting checks and added missing test config file</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Update cli.py to support custom loggers

Allows a config.py file (via rq worker --config) to support things like this for logfmt logging:

DICT_CONFIG = {
        "version": 1,
        "formatters": {"logfmt": {
            "()": "logfmter.Logfmter",
            "keys": ["level","when","pid"],
            "mapping": {"level":"levelname","when":"asctime","pid":"process"},
            "datefmt": "%Y-%m-%dT%H:%M:%S%z"
            }},
        "handlers": {"console": {"class": "logging.StreamHandler","formatter": "logfmt" }},
        "loggers": {
            "root": {"handlers":["console"], "level": "INFO"},
            "rq":   {"handlers":["console"], "level": "INFO", "propagate": False},
            }
        }

* added simple test and documentation for DICT_CONFIG

* further attempt to get testing right for dictConfig

* move import to correct location

* fix

* remove meaningless options.get() usage

* linting checks and added missing test config file</pre>
</div>
</content>
</entry>
<entry>
<title>Update linting configuration (#1915)</title>
<updated>2023-05-17T16:19:14+00:00</updated>
<author>
<name>Rob Hudson</name>
<email>robhudson@mozilla.com</email>
</author>
<published>2023-05-17T16:19:14+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=ea063edf0a790630d0800808fe6236b3e9ddcf22'/>
<id>ea063edf0a790630d0800808fe6236b3e9ddcf22</id>
<content type='text'>
* Update linting configuration

This removes flake8 in favor of ruff, which also provides isort support, and
updates all files to be black, isort, and ruff compliant. This also adds black
and ruff checks to the tox and Github linting workflow.

* Tweak the code coverage config and calls</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Update linting configuration

This removes flake8 in favor of ruff, which also provides isort support, and
updates all files to be black, isort, and ruff compliant. This also adds black
and ruff checks to the tox and Github linting workflow.

* Tweak the code coverage config and calls</pre>
</div>
</content>
</entry>
<entry>
<title>Worker pool (#1874)</title>
<updated>2023-05-01T05:44:32+00:00</updated>
<author>
<name>Selwin Ong</name>
<email>selwin.ong@gmail.com</email>
</author>
<published>2023-05-01T05:44:32+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=64cb1a27b9d1f2fd52bbbb5c1e4518c024f74685'/>
<id>64cb1a27b9d1f2fd52bbbb5c1e4518c024f74685</id>
<content type='text'>
* First stab at implementating worker pool

* Use process.is_alive() to check whether a process is still live

* Handle shutdown signal

* Check worker loop done

* First working version of `WorkerPool`.

* Added test for check_workers()

* Added test for pool.start()

* Better shutdown process

* Comment out test_start() to see if it fixes CI

* Make tests pass

* Make CI pass

* Comment out some tests

* Comment out more tests

* Re-enable a test

* Re-enable another test

* Uncomment check_workers test

* Added run_worker test

* Minor modification to dead worker detection

* More test cases

* Better process name for workers

* Added back pool.stop_workers() when signal is received

* Cleaned up cli.py

* WIP on worker-pool command

* Fix test

* Test that worker pool ignores consecutive shutdown signals

* Added test for worker-pool CLI command.

* Added timeout to CI jobs

* Fix worker pool test

* Comment out test_scheduler.py

* Fixed worker-pool in burst mode

* Increase test coverage

* Exclude tests directory from coverage.py

* Improve test coverage

* Renamed `Pool(num_workers=2) to `Pool(size=2)`

* Revert "Renamed `Pool(num_workers=2) to `Pool(size=2)`"

This reverts commit a1306f89ad0d8686c6bde447bff75e2f71f0733b.

* Renamed Pool to WorkerPool

* Added a new TestCase that doesn't use LocalStack

* Added job_class, worker_class and serializer arguments to WorkerPool

* Use parse_connection() in WorkerPool.__init__

* Added CLI arguments for worker-pool

* Minor WorkerPool and test fixes

* Fixed failing CLI test

* Document WorkerPool</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* First stab at implementating worker pool

* Use process.is_alive() to check whether a process is still live

* Handle shutdown signal

* Check worker loop done

* First working version of `WorkerPool`.

* Added test for check_workers()

* Added test for pool.start()

* Better shutdown process

* Comment out test_start() to see if it fixes CI

* Make tests pass

* Make CI pass

* Comment out some tests

* Comment out more tests

* Re-enable a test

* Re-enable another test

* Uncomment check_workers test

* Added run_worker test

* Minor modification to dead worker detection

* More test cases

* Better process name for workers

* Added back pool.stop_workers() when signal is received

* Cleaned up cli.py

* WIP on worker-pool command

* Fix test

* Test that worker pool ignores consecutive shutdown signals

* Added test for worker-pool CLI command.

* Added timeout to CI jobs

* Fix worker pool test

* Comment out test_scheduler.py

* Fixed worker-pool in burst mode

* Increase test coverage

* Exclude tests directory from coverage.py

* Improve test coverage

* Renamed `Pool(num_workers=2) to `Pool(size=2)`

* Revert "Renamed `Pool(num_workers=2) to `Pool(size=2)`"

This reverts commit a1306f89ad0d8686c6bde447bff75e2f71f0733b.

* Renamed Pool to WorkerPool

* Added a new TestCase that doesn't use LocalStack

* Added job_class, worker_class and serializer arguments to WorkerPool

* Use parse_connection() in WorkerPool.__init__

* Added CLI arguments for worker-pool

* Minor WorkerPool and test fixes

* Fixed failing CLI test

* Document WorkerPool</pre>
</div>
</content>
</entry>
<entry>
<title>Added changelog</title>
<updated>2023-05-01T05:43:45+00:00</updated>
<author>
<name>Selwin Ong</name>
<email>selwin.ong@gmail.com</email>
</author>
<published>2023-05-01T05:43:45+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=8a9daecaf2c6ff542ec1e4be7d8ec9ae4c8b803c'/>
<id>8a9daecaf2c6ff542ec1e4be7d8ec9ae4c8b803c</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>improve the docs on in-flight jobs of killed/lost workers (#1840)</title>
<updated>2023-04-01T12:50:39+00:00</updated>
<author>
<name>luto</name>
<email>m@luto.at</email>
</author>
<published>2023-04-01T12:50:39+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=4f3670b024ef14721fefdff690919fd302eeeb9c'/>
<id>4f3670b024ef14721fefdff690919fd302eeeb9c</id>
<content type='text'>
* improve the docs on in-flight jobs of killed/lost workers

* improve the docs on in-flight jobs of killed/lost workers

* document abandoned job behavior before 0.14</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* improve the docs on in-flight jobs of killed/lost workers

* improve the docs on in-flight jobs of killed/lost workers

* document abandoned job behavior before 0.14</pre>
</div>
</content>
</entry>
<entry>
<title>Fix error in example in the documentation (#1870)</title>
<updated>2023-04-01T12:43:47+00:00</updated>
<author>
<name>Joris</name>
<email>j.h.hoendervangers@gmail.com</email>
</author>
<published>2023-04-01T12:43:47+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=a9fae76e883eb1bba8e8f62406669371e12d1f4b'/>
<id>a9fae76e883eb1bba8e8f62406669371e12d1f4b</id>
<content type='text'>
The solution that @rpkak proposes works. Closes #1524</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
The solution that @rpkak proposes works. Closes #1524</pre>
</div>
</content>
</entry>
<entry>
<title>Consolidate job callbacks execution (#1851)</title>
<updated>2023-03-20T23:44:41+00:00</updated>
<author>
<name>Rony Lutsky</name>
<email>3050627+ronlut@users.noreply.github.com</email>
</author>
<published>2023-03-20T23:44:41+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=04722339d7598ff0c52f11c3680ed2dd922e6768'/>
<id>04722339d7598ff0c52f11c3680ed2dd922e6768</id>
<content type='text'>
* consolidate job failure callback execution

* fix

* success callback as well

* merge fix

* create Callback class and change how callbacks serde

* deprecation

* add tests

* string format

* pr fix

* revert serialization changes

* fix timeout typing

* add documentation

* add test

* fix a bug

* fix tests

* move job heartbeat call to worker and make sure there is always a callback timeout

* fix test

* fix test</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* consolidate job failure callback execution

* fix

* success callback as well

* merge fix

* create Callback class and change how callbacks serde

* deprecation

* add tests

* string format

* pr fix

* revert serialization changes

* fix timeout typing

* add documentation

* add test

* fix a bug

* fix tests

* move job heartbeat call to worker and make sure there is always a callback timeout

* fix test

* fix test</pre>
</div>
</content>
</entry>
<entry>
<title>Remove `use_connection` (#1859)</title>
<updated>2023-03-07T03:54:47+00:00</updated>
<author>
<name>lowercase00</name>
<email>21188280+lowercase00@users.noreply.github.com</email>
</author>
<published>2023-03-07T03:54:47+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=d5bde117c2f5477b5d0ba9846f2a7c4480ca1854'/>
<id>d5bde117c2f5477b5d0ba9846f2a7c4480ca1854</id>
<content type='text'>
* feat: remove use_connection

* fix: clear old test</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* feat: remove use_connection

* fix: clear old test</pre>
</div>
</content>
</entry>
<entry>
<title>Update arguments passed to the Sentinel Object when created from the settings (#1850)</title>
<updated>2023-03-07T03:03:31+00:00</updated>
<author>
<name>Joachim Burket</name>
<email>joachimBurket@users.noreply.github.com</email>
</author>
<published>2023-03-07T03:03:31+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=7f9f0f72ba1adac907791d604d5f56af8125fdfd'/>
<id>7f9f0f72ba1adac907791d604d5f56af8125fdfd</id>
<content type='text'>
* Updated arguments passed to the Sentinel Object when created from the settings

- added `USERNAME` key
- added `CONNECTION_KWARGS` key to allow passing additionals arguments to the Redis connections
- updated the documentation

* added missing comma

* tests(helpers): Added tests for Sentinel

---------

Co-authored-by: Joachim Burket &lt;joachim.burket@hopitalvs.ch&gt;</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
* Updated arguments passed to the Sentinel Object when created from the settings

- added `USERNAME` key
- added `CONNECTION_KWARGS` key to allow passing additionals arguments to the Redis connections
- updated the documentation

* added missing comma

* tests(helpers): Added tests for Sentinel

---------

Co-authored-by: Joachim Burket &lt;joachim.burket@hopitalvs.ch&gt;</pre>
</div>
</content>
</entry>
<entry>
<title>Update index.md (#1858)</title>
<updated>2023-03-06T23:55:08+00:00</updated>
<author>
<name>Tianci Hu Marrero</name>
<email>69414708+iggeehu@users.noreply.github.com</email>
</author>
<published>2023-03-06T23:55:08+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/python-packages/rq.git/commit/?id=5de8cda1f9adf5553e4759f84d22e53916802f39'/>
<id>5de8cda1f9adf5553e4759f84d22e53916802f39</id>
<content type='text'>
fixed minor duplicate article ("the its config var")</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
fixed minor duplicate article ("the its config var")</pre>
</div>
</content>
</entry>
</feed>
