github.com/hibiken/asynq commits | Ecosyste.ms: OpenCollective

Update go.mod with replace directive

8a4fb71dd5b45b63b4e9bc3914349bf18193375e authored over 2 years ago by Ken Hibino <[email protected]>

Update ForwardIfReady test with group

ed69667e86ef9df4da31b7d7c91482765b363f45 authored over 2 years ago by Ken Hibino <[email protected]>

Add Inspector.ListAggregatingTasks

7fb5b2594422c4511243effbfdc0161ccb8dc14d authored over 2 years ago by Ken Hibino <[email protected]>

Add Inspector.Groups method

4c8432e0ce7d78a59f5c8e61b752a5c1ed52c513 authored over 2 years ago by Ken Hibino <[email protected]>

Rename asynqtest package to testutil

e939b5d166a42032cf9aaa5e5c68c9284358591c authored over 2 years ago by Ken Hibino <[email protected]>

Move test helpers to asynqtest package

1acd62c76038196d1e58f2ee06f40467d062a560 authored over 2 years ago by Ken Hibino <[email protected]>

(cli): Update queue inspect cmd to show # of groups and aggregating tasks

01eeb8756effe5b1dbdf0ebef49743de9f169eb3 authored over 2 years ago by Ken Hibino <[email protected]>

Add Group field to TaskInfo struct

45ed56070866a5fe60a30ef4cddf47e01551ee3b authored over 2 years ago by Ken Hibino <[email protected]>

Fix RDB.CurrentStats to report the correct queue size

47af17cfb4f1e02a2ee6c6113b5e2f891a733c16 authored over 2 years ago by Ken Hibino <[email protected]>

Fix client to return error when nil task is passed

562506c7baf6c196b3beb049a7a406071ec2a4ad authored over 2 years ago by Ken Hibino <[email protected]>

Use zset for aggregation set to preserve score

3551d3334c57b119f36fe4983807cf5cfc67ca26 authored over 2 years ago by Ken Hibino <[email protected]>

Update memory usage redis lua script to account for groups

652939dd3a317fe2045bcbc5b1032a5944acaee2 authored over 2 years ago by Ken Hibino <[email protected]>

Clear group if aggregation set empties the group

74d2eea4e03435cb76d08710121d638a661920bf authored over 2 years ago by Ken Hibino <[email protected]>

Rewrite test for DeleteAggregationSet function with a new pattern

4b716780effcb705d3c308d32985229c56ea9abc authored over 2 years ago by Ken Hibino <[email protected]>

Show number of groups and aggregating task count in QueueInfo

efe3c74037bd36d3310ea253e4f39ea1ca299b19 authored over 2 years ago by Ken Hibino <[email protected]>

Fix DeleteAggregationSet

e63f41fb24fd3ada433cc7bb204ca66869366db6 authored over 2 years ago by Ken Hibino <[email protected]>

Use explicit types for limit constants

3f4f0c1daa886fb72f06621f16c5f46a80e1ab52 authored almost 3 years ago by ashang <[email protected]>

Add go1.18 to build workflow matrix

f94a65dc9f6cb0e5f56b3966a40490c8ba839678 authored almost 3 years ago by Ken Hibino <[email protected]>

Add rediss url parsing support

04d7c8c38cf9919d33eccbc0495a583d31451488 authored almost 3 years ago by Erwan Leboucher <[email protected]>

v0.22.1

c04fd4165318906f783ba35a8107e9b8cf2bdffa authored almost 3 years ago by Ken Hibino <[email protected]>

Drop GT option from RDB.ExtendLease

GT option in ZAdd is supported for redis v6.2.0 or above.
This Change fixes redis version compat...

7e5efb0e307054984277cb2b0802d3cec7af4a3e authored almost 3 years ago by Ken Hibino <[email protected]>

Fix changelog

cabf8d36273ced35d2df62cde4001b43ab7748bd authored almost 3 years ago by Ken Hibino <[email protected]>

v0.22.0

a19909f5f4197023a389422bed610fdb12bca518 authored almost 3 years ago by Ken Hibino <[email protected]>

Fix processor test

ec560afb0167e146f763d1d2e7fbed4884f9eeb6 authored almost 3 years ago by Ken Hibino <[email protected]>

Remove base.DeadlinesKey

d4006894ad22dbc8d412c3037868731a6c0ad242 authored almost 3 years ago by Ken Hibino <[email protected]>

Remove timeout and deadline fields under task key

59927509d8550a4fb7ce819222c24681c8a572e6 authored almost 3 years ago by Ken Hibino <[email protected]>

Update processor to create a lease and watch for expiration

8211167de252e5e5d25d4d317d9f62109f2d100b authored almost 3 years ago by Ken Hibino <[email protected]>

Update heartbeat to extend lease of active workers

d7169cd44596915bbfb0551476ebd9522f5f87a6 authored almost 3 years ago by Ken Hibino <[email protected]>

Move task deadline compute logic to processor

bca624792ccdcf63357f8d98e3cc8c5d9dc9c18a authored almost 3 years ago by Ken Hibino <[email protected]>

Add Lease type to base package

b9943de2ab99d99e54b6675e7cc00cff78d19bc7 authored almost 3 years ago by Ken Hibino <[email protected]>

Update heartbeat goroutine to call ExtendLease on active tasks

871474f220fe5d843955894c03f0331fad9c8ad1 authored almost 3 years ago by Ken Hibino <[email protected]>

Add RDB.ExtendLease method

87dc392c7f4436df3816438fbcbc54e70b90fc1e authored almost 3 years ago by Ken Hibino <[email protected]>

Update recoverer to use ListLeaseExpired

dabcb120d587ff249969822ae87b866d2a430852 authored almost 3 years ago by Ken Hibino <[email protected]>

Update ListDeadlineExceeded to ListLeaseExpired

bc2f1986d7579197084ce34b26c284ae8b149600 authored almost 3 years ago by Ken Hibino <[email protected]>

Update RDB methods to use lease instead of deadlines set

b8cb5794077e4111763ddd772e094f0199a1640c authored almost 3 years ago by Ken Hibino <[email protected]>

Update RDB methods to work with lease

dfae8638e16be80cc10106f493994c854a1e9829 authored almost 3 years ago by Ken Hibino <[email protected]>

Update RDB.Dequeue to insert task ID to lease set

d865d899007f6160dfdbacfc3fee3415f47a73dc authored almost 3 years ago by Ken Hibino <[email protected]>

Update log messages

9b63e2327443979bb8daa5e829949c6a5c3999b0 authored almost 3 years ago by Ken Hibino <[email protected]>

Make timeutil.SimulatedClock concurrency safe

de25201d9fbb640a0d268c95758487857f62d634 authored almost 3 years ago by Ken Hibino <[email protected]>

Add IsOrphaned field to TaskInfo

cea5110d15a307045060fc7b8598bd4918ec373b authored almost 3 years ago by Ken Hibino <[email protected]>

Add base.LeaseKey helper function

852af7abd125a46cd9186784082f5def7817efc8 authored almost 3 years ago by Ken Hibino <[email protected]>

Fix tests

5490d2c6257a86600ea5b198b97b27e6e0ab076f authored almost 3 years ago by Ken Hibino <[email protected]>

conventions

ebd7a32c0f72132867923dd3d2978c8ae9680f67 authored almost 3 years ago by Binaek Sarkar <[email protected]>

test and changelog

55d0610a037e8588aa8e2eebbf05a7554cd6386a authored almost 3 years ago by Binaek Sarkar <[email protected]>

review corrections

ab8a4f5b1ee8a8c4c25fd72f540ba80c3f148281 authored almost 3 years ago by Binaek Sarkar <[email protected]>

first cut

d7ceb0c0909b0af827e3b7dcd8dc8a0373f94cc1 authored almost 3 years ago by Binaek Sarkar <[email protected]>

(ci): Run go (build|test) commands for each module

8bd70c6f845d8ecdc83cadf8988a19289cfcf3e3 authored almost 3 years ago by Ken Hibino <[email protected]>

Remove replace directives in go.mod

10ab4e3745a4855b1faf47e8407b78b0ae0a25a9 authored almost 3 years ago by Ken Hibino <[email protected]>

Add example for ResultWriter

349f4c50fb1d8190c48a701e96b59498a0fd1a9e authored almost 3 years ago by Ken Hibino <[email protected]>

v0.21.0

dff2e3a33639338c648599bf6ea83f835feec4bf authored almost 3 years ago by Ken Hibino <[email protected]>

Update changelog

65040af7b512b8c24a9ea569cec4bfc2b824759a authored almost 3 years ago by Ken Hibino <[email protected]>

Create PeriodicTaskManager

053fe2d1eec912da22efd6b1179c55457cf8e063 authored almost 3 years ago by Ken Hibino <[email protected]>

Fix bug related to concurrently executing server state changes

25832e5e952cea0256c047650efe3826e6464f60 authored almost 3 years ago by Ken Hibino <[email protected]>

Fix flaky tests

aa26f3819ede4887846e235733b92f4e685c2af2 authored almost 3 years ago by Ken Hibino <[email protected]>

Add CODE_OF_CONDUCT.md

d94614bb9baa340f86525bd4c408b98752d5c0c8 authored almost 3 years ago by Ken Hibino <[email protected]>

Allow configuration of DelayedTaskCheckInterval

ce46b076525b53232c1d1267e36accf8f237d0fd authored almost 3 years ago by Mahdi Dibaiee <[email protected]>

Add --json flag for asynq stats command

2d0170541c8ebc35b9371840cef62043089a5dfe authored about 3 years ago by Mahdi Dibaiee <[email protected]>

fix: missing import statement in example code

c1f08106da7cb29eb5663979ab753a6d58483e48 authored about 3 years ago by Andreas Thomas <[email protected]>

Update readme

74cf804197bfa094815a2555e2498700a38b3adf authored about 3 years ago by Ken Hibino <[email protected]>

Fix build

8dfabfccb3be1bfa4847480b7605749b4cdac463 authored about 3 years ago by Ken Hibino <[email protected]>

v0.20.0

5f20edcbd10b92950aa2a1d2b69e9bf8316a642a authored about 3 years ago by Ken Hibino <[email protected]>

Use math.MaxInt64 instead of custom const

1ddb2f7bcecb7cd0302b569b8e3ed791e403b78c authored about 3 years ago by Ken Hibino <[email protected]>

Record total tasks processed/failed

82d18e3d91274db9adae9517a194359bdd614e21 authored about 3 years ago by Ken Hibino <[email protected]>

Add queue metrics exporter

Changes:
- Added `x/metrics` package
- Added `tools/metrics_exporter` binary

43cb4ddf1984a9cc057e6250e9e6c293a5a53fef authored about 3 years ago by Ken Hibino <[email protected]>

Fix typo in Server doc

ddfc6747a1613df48e6b8d0660e642557157a3de authored about 3 years ago by Francisco Miamoto <[email protected]>

v0.19.1

970cb7a6067abfa2b926f6e64ca2d4372e682e42 authored about 3 years ago by Ken Hibino <[email protected]>

Update changelog

157e97e72e247ae6d999d76cba11f31425c212fb authored about 3 years ago by Ken Hibino <[email protected]>

Record time when task moved to pending state

6e7106c8f2d1dc4719966392d76d8637875e0620 authored about 3 years ago by Ken Hibino <[email protected]>

Add Latency field to QueueInfo

99a6750656690654dc0ce5660c6629e3671c4275 authored about 3 years ago by Ken Hibino <[email protected]>

Delete "pending_since" under task-key when state changes to active

22e6c9d297f997343d1e01ffd9877f6db12e0f4a authored about 3 years ago by Ken Hibino <[email protected]>

Use clock in RDB

e7c1c3ad6f747b3e86aa18d573f446270e6228aa authored about 3 years ago by Ken Hibino <[email protected]>

Add internal timeutil package

c9183374c5ee4b1d2bed3e9ff097a4d04a1d51a7 authored about 3 years ago by Ken Hibino <[email protected]>

Add EnqueueContext method to Client

9f2c321e9804901f06b58e82f9e0ce4125d80b74 authored about 3 years ago by Ken Hibino <[email protected]>

Return error if Unique TTL is less than 1s

e2b61c9056a1c71888e57852ec6431ce44cd82cf authored about 3 years ago by Ken Hibino <[email protected]>

Fix godoc around errors returned from Inspector

531d1ef0894b5d247204c0d5d738d441853a1208 authored about 3 years ago by Ken Hibino <[email protected]>

v0.19.0

413afc2ab6f8347b863251a642219c46ad731cc3 authored about 3 years ago by Ken Hibino <[email protected]>

Introduce Task Results

* Added Retention Option to specify retention TTL for tasks
* Added ResultWriter as a client in...

f4ddac4dcc60e58424a0676fa4492233289e4904 authored about 3 years ago by Ken Hibino <[email protected]>

Add TaskID option to allow user to specify task id

9e2f88c00dfde884731cb66931f895ff44fafa30 authored about 3 years ago by Ken Hibino <[email protected]>

Update readme

6bb481850971dbcbfbb203e09ef18191892826b1 authored about 3 years ago by Ken Hibino <[email protected]>

Update RDB Enqueue and Schedule methods to check for task ID conflict

dbdd9c6d5f1784c282224a10d8c790f4dd1fa6a7 authored about 3 years ago by Ken Hibino <[email protected]>

Fix flaky test

4638405cbdb39574eab9fc9c07c0f7d750dcb75e authored about 3 years ago by Ken Hibino <[email protected]>

Update NewTask function to take Option as varargs

83cae4bb24916caf2ab6f5f48cde029bbefb7d98 authored about 3 years ago by Ken Hibino <[email protected]>

Change TaskMessage.ID type from uuid.UUID to string

2261c7c9a0a969a788447a305707f7183d8225a7 authored about 3 years ago by Ken Hibino <[email protected]>

Add asynq/x/rate package

- Added a directory /x for external, experimental packeges
- Added a `rate` package to enable r...

23c522dc9feb95e055786f8fff9d04b973eedbb6 authored about 3 years ago by Ajat Prabha <[email protected]>

Add FUNDING.yml

0d2c0f612b1e772ca079d6b0021071240f46e285 authored over 3 years ago by Ken Hibino <[email protected]>

v0.18.6

d612a8a9e436be9c2cbee7a21ccc0c5488426f70 authored over 3 years ago by Ken Hibino <[email protected]>

Upgrade go-redis/redis to version 8

b3ef9e91a9cec1f9890f3f34653aaf6b90388dbd authored over 3 years ago by Jason White <[email protected]>

v0.18.5

05534c6f248799ed3c01717f1076df522e03bd52 authored over 3 years ago by Ken Hibino <[email protected]>

Add IsFailure to Config

With this IsFailure config, users can provide a predicate function to
determine whether the er...

f0db219f6a5c535579850592fba9e8d117ed7ff9 authored over 3 years ago by Ken Hibino <[email protected]>

Fix readme

3ae0e7f528fa89acddd25fe551792adbfdf359e5 authored over 3 years ago by Mehran Poursadeghi <[email protected]>

v0.18.4

421dc584ffa4fab4ea8ced5546b9234d2dfedd82 authored over 3 years ago by Ken Hibino <[email protected]>

Make scheduler methods thread-safe

cfd1a1dfe8fb4b1001c84c7e803ae64afd4949f3 authored over 3 years ago by Ken Hibino <[email protected]>

v0.18.3

c197902dc0726ab2a17520d7c90b6b31a31f25b9 authored over 3 years ago by Ken Hibino <[email protected]>

Use approximate memory usage for QueueInfo

e6355bf3f54c983ab0d1f79ece6aa74fd638712d authored over 3 years ago by Ken Hibino <[email protected]>

Adjust error message, use TrimSpace for more robust empty typename check

6817af366aa3bc35c3624578bf319579a0a87c94 authored over 3 years ago by Luqqk <[email protected]>

client.Enqueue - prevent empty task's typename

4bce28d677210c1fbf6a7554a4a400d52087e770 authored over 3 years ago by Luqqk <[email protected]>

Add changelog entry, add additional test case

95c90a5cb822877a9465cd3203235a262359096f authored over 3 years ago by Luqqk <[email protected]>

Fixes links

73f930313cef4434c7a62f54bece8051788fa89c authored over 3 years ago by Pedro Henrique <[email protected]>

Fix examples in readme

bff2a05d592b8918bfec7c76c4a6664154fb5310 authored over 3 years ago by Ken Hibino <[email protected]>

v0.18.2

684a7e0c984347986ffb88f22298b0a4da80847f authored over 3 years ago by Ken Hibino <[email protected]>