Releases: metaist/ezq
Releases · metaist/ezq
3.0.4
3.0.3
3.0.2
3.0.1
3.0.0
3.0.0 - 2023-05-18T09:58:43Z
Fixed
- GitHub Action: continuous integration
- #9:
multiprocessing
on MacOS (by switching tomultiprocess
)
Changed
- #8: order of
Msg
parameters so thatdata
comes first - #9: core library is now
multiprocess
instead ofmultiprocessing
;dill
replacespickle
.
Added
- GitHub Action:
mypy
check for examples and tests - supported python versions badge
- #5:
Worker
wrapper forProcess
andThread
cSpell
to track ignored words
Removed
- #7: deprecated functions:
put_msg
,iter_msg
,iter_q
,sortiter
,endq
,endq_and_wait
2.0.3
2.0.3 - 2023-05-10T03:44:15Z
This version introduced a new class-based API via the Q
object.
The function-based API is officially deprecated and will be removed
in v3.
Changed
sortiter
now sorts the list of waiting messages in place to improve performance (~50%).- replaced
pylint
withruff
- #6: supported python versions: removed 3.6, 3.7; added 3.10, 3.11
Added
- build badge
- #1: support for
threading
- #3:
map
function for simple use-cases - #4:
Q
class wrapper for the queue
Deprecated
Most of the function-based API is now deprecated.
put_msg
: useQ.put()
insteaditer_msg
: useiter(Q)
insteaditer_q
: useQ.items()
insteadsortiter
: useQ.sorted()
insteadendq
: useQ.end()
insteadendq_and_wait
: useQ.stop()
instead
2.0.2
2.0.2 - 2021-08-24T17:25:52Z
Removed
count
parameter forendq
; it was only used interally and was confusing
Changed
iter_msg
to handleblock
parameteriter_sortq
to be a more genericsortiter
Added
- Documention
sortiter
which is a more general form ofiter_sortq
iter_q
for iterating over current contents of a queue
2.0.1
2.0.0
2.0.0 - 2021-08-22T19:56:48Z
Removed
IS_ALIVE
,stop_iter_msg()
: Originally, these were to stopiter_msg()
from continuing when there was aSIGINT
. However, this didn't really work properly and so was removed.Daemon
,start_processes()
,start()
,start_numbered()
: these have all been replaced with a simplerrun()
function.
Changed
iter_msg()
no longer checks against a globalIS_ALIVE
boolean. It runs until the queue is ended or the process is killed (possibly throwing errors).wait()
is now calledendq_and_wait
to more clearly explain its function.
Added
iter_sortq()
: iterates over the contents of a queue in a sorted way. Useful for collating results in a single process at the end of a pipeline.endq()
: adds the specialEND_MSG
to the queue. This makes the API cleaner in terms of ending queues that don't require waiting.
Updated
- README with more examples and key concepts.