chore: re-enable test thats no longer flaky

block · Dec 17, 2024 · 1f43891 · 1f43891
1 parent ca17408
commit 1f43891
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 7 deletions.
diff --git a/backend/runner/pubsub/integration_test.go b/backend/runner/pubsub/integration_test.go
@@ -17,7 +17,6 @@ import (
 )
 
 func TestPubSub(t *testing.T) {
-	t.Skip("Skipping flaky test")
 	calls := 20
 	events := calls * 10
 	in.Run(t,

diff --git a/...stdata/kotlin/subscriber/src/main/kotlin/xyz/block/ftl/java/test/subscriber/Subscriber.kt b/...stdata/kotlin/subscriber/src/main/kotlin/xyz/block/ftl/java/test/subscriber/Subscriber.kt
@@ -28,12 +28,6 @@ class Subscriber {
         throw RuntimeException("always error: event " + event.time)
     }
 
-    @Subscription(topic = Topic2Topic::class, from = FromOffset.BEGINNING)
-    @Retry(count = 1, minBackoff = "1s", maxBackoff = "1s", catchVerb = "catchAny")
-    fun consumeButFailAndCatchAny(event: PubSubEvent) {
-        throw RuntimeException("always error: event " + event.time)
-    }
-
     @Verb
     @VerbName("catch")
     fun catchVerb(req: CatchRequest<PubSubEvent?>) {