Skip to content

Commit

Permalink
Remove a test that doesn't make sense in a root env (like in a Docker…
Browse files Browse the repository at this point in the history
… container)
  • Loading branch information
CorentinB committed Jul 12, 2024
1 parent 2abaf8e commit ea748ea
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 9 deletions.
1 change: 0 additions & 1 deletion .github/workflows/go.yml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ jobs:
run: go build -v ./...

- name: Test
continue-on-error: true
run: go test -race -v ./...

- name: Goroutine leak detector
Expand Down
2 changes: 2 additions & 0 deletions internal/pkg/queue/dequeue.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@ import (
"io"
)

// Dequeue removes and returns the next item from the queue
// It blocks until an item is available
func (q *PersistentGroupedQueue) Dequeue() (*Item, error) {
if q.closed {
return nil, ErrQueueClosed
Expand Down
8 changes: 0 additions & 8 deletions internal/pkg/queue/queue_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -144,16 +144,8 @@ func TestNewPersistentGroupedQueue(t *testing.T) {
if q.currentHost != 0 {
t.Error("currentHost not initialized to 0")
}

// Test error case: invalid directory
_, err = NewPersistentGroupedQueue("/invalid/path", loggingChan)
if err == nil {
t.Error("Expected error for invalid directory, got nil")
}
}

// In internal/pkg/queue/queue_test.go

func TestPersistentGroupedQueue_Close(t *testing.T) {
tempDir, err := os.MkdirTemp("", "queue_test")
if err != nil {
Expand Down

0 comments on commit ea748ea

Please sign in to comment.