diff --git a/machinery/src/components/backchannel_test.go b/machinery/src/components/backchannel_test.go
index e0644fc..b1c80bf 100644
--- a/machinery/src/components/backchannel_test.go
+++ b/machinery/src/components/backchannel_test.go
@@ -206,4 +206,4 @@ func TestWriteAudioToBackchannelCancellationStopsReconnect(t *testing.T) {
 	case <-time.After(250 * time.Millisecond):
 		t.Fatal("cancellation did not interrupt reconnect backoff")
 	}
-}
\ No newline at end of file
+}
diff --git a/machinery/src/routers/mqtt/main_test.go b/machinery/src/routers/mqtt/main_test.go
index 1773fb9..efb3cc9 100644
--- a/machinery/src/routers/mqtt/main_test.go
+++ b/machinery/src/routers/mqtt/main_test.go
@@ -2,6 +2,7 @@ package mqtt
 
 import (
 	"testing"
+	"time"
 
 	"github.com/kerberos-io/agent/machinery/src/models"
 )
@@ -32,7 +33,7 @@ func TestEnqueueLatestAudioDoesNotBlockNilChannel(t *testing.T) {
 
 	select {
 	case <-done:
-	default:
+	case <-time.After(100 * time.Millisecond):
 		t.Fatal("enqueueLatestAudio() blocked on a nil channel")
 	}
-}
\ No newline at end of file
+}