Releases: talkiq/gcloud-aio
Releases · talkiq/gcloud-aio
taskqueue-1.2.5
TaskManager
- fix: handle BrokenProcessPool explicitly
taskqueue-1.2.4
TaskManager
- fix: catch pool errors in LeaseManager.stop()
- fix: mark ProcessPool as broken in all exception cases
taskqueue-1.2.3
TaskManager
- feature: allow in-flight tasks to be processed (ie. finish) on pool death
taskqueue-1.2.2
TaskManager
- fix: catch and handle edge case subprocessing errors
TaskQueue
- fix: ensure retryable tasks can not return null
taskqueue-1.2.1
TaskManager
- fix executor shutdown ordering issue
TaskQueue
- feat: raise 429 on retry exhaustion
taskqueue-1.2.0
TaskManager
- fix: ensure ProcessPoolExecutor shuts down cleanly on
.stop()
call - fix: fix unbounded memory growth issue in process executors
- fix: prevent error with multiple event loops
taskqueue-1.1.1
TaskManager
- fix: use single
multiprocessing.Manager
instance across all processes to reduce CPU usage - fix: ensure LeaseManager process always exits
TaskQueue
- refactor: clean up retry/raise request handlers
taskqueue-1.1.0
TaskManager
- feat: lease management is now multiprocess-based, so heavy workloads should not cause lease loses
TaskQueue
- feat: taskqueues will retry on ServerDisconnects, which may occur when making concurrent requests to Google APIs
taskqueue-1.0.6
TaskQueue
- minor: better logging on failed methods
taskqueue-1.0.5
Features
- default ClientSession now has timeout values set
Fixes
- gracefully handle exceptions in TaskManager lease
- fix casting error when
lease_seconds
is a float