mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-04-20 16:52:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: tests

Browse Source
This commit is contained in:
Gabe Ruttner
2026-03-15 11:39:14 -04:00
parent 130892cbee
commit fdac15a854
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/msgqueue/rabbitmq/rabbitmq_test.go
+2 -1
View File
@@ -343,7 +343,8 @@ func TestDeadLetteringSuccess(t *testing.T) {
// deleteQueue is a helper function for removing durable queues which are used for tests.
func (t *MessageQueueImpl) deleteQueue(q msgqueue.Queue) error {
poolCh, err := t.subChannels.Acquire(context.Background())
ctx := context.Background()
poolCh, err := t.subChannels.Acquire(ctx)
if err != nil {
t.l.Error().Ctx(ctx).Msgf("[deleteQueue] cannot acquire channel for deleting queue: %v", err)