diff options
| author | Stefan van den Oord <stefan@viduet.eu> | 2025-09-16 11:10:02 +0200 |
|---|---|---|
| committer | Stefan van den Oord <stefan@viduet.eu> | 2025-09-16 11:10:02 +0200 |
| commit | 698ab89d3a48fd6c42f0abbb1fb6b6c9e8d4d53a (patch) | |
| tree | 945ea4d0602fb4d4d951d7ab1de73baf94342f7b /test | |
| parent | Rename batch -> job-group (diff) | |
| download | fiinha-698ab89d3a48fd6c42f0abbb1fb6b6c9e8d4d53a.tar.gz fiinha-698ab89d3a48fd6c42f0abbb1fb6b6c9e8d4d53a.tar.xz | |
Improve naming: job-group is a keyword, so don't include "-name"
Diffstat (limited to 'test')
| -rw-r--r-- | test/com/github/ivarref/yoltq/virtual_test.clj | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/test/com/github/ivarref/yoltq/virtual_test.clj b/test/com/github/ivarref/yoltq/virtual_test.clj index d245aaa..a2ed269 100644 --- a/test/com/github/ivarref/yoltq/virtual_test.clj +++ b/test/com/github/ivarref/yoltq/virtual_test.clj @@ -456,19 +456,19 @@ (yq/init! {:conn conn}) (yq/add-consumer! :q1 identity) (yq/add-consumer! :q2 identity) - @(d/transact conn [(yq/put :q1 {:work 123} {:job-group-name :b1}) - (yq/put :q1 {:work 456} {:job-group-name :b2}) - (yq/put :q2 {:work 789} {:job-group-name :b1})]) + @(d/transact conn [(yq/put :q1 {:work 123} {:job-group :group1}) + (yq/put :q1 {:work 456} {:job-group :group2}) + (yq/put :q2 {:work 789} {:job-group :group1})]) (is (= [{:qname :q1 - :job-group-name :b1 + :job-group :group1 :status :init :count 1}] - (yq/job-group-progress :q1 :b1))) + (yq/job-group-progress :q1 :group1))) (is (= {:work 123} (tq/consume! :q1))) (is (= [{:qname :q1 - :job-group-name :b1 + :job-group :group1 :status :done :count 1}] - (yq/job-group-progress :q1 :b1))))) + (yq/job-group-progress :q1 :group1))))) |