1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
diff --git a/pubsub/flow_controller_test.go b/pubsub/flow_controller_test.go
index 71c41cbf16..2ff80e87fd 100644
--- a/pubsub/flow_controller_test.go
+++ b/pubsub/flow_controller_test.go
@@ -233,6 +233,7 @@ func TestFlowControllerUnboundedCount2(t *testing.T) {
}
}
+/*
func TestFlowControllerUnboundedBytes(t *testing.T) {
t.Parallel()
ctx := context.Background()
@@ -253,3 +254,4 @@ func TestFlowControllerUnboundedBytes(t *testing.T) {
t.Error("got true, wanted false")
}
}
+*/
diff --git a/pubsub/integration_test.go b/pubsub/integration_test.go
index 9fbcf12091..9dd4e2c769 100644
--- a/pubsub/integration_test.go
+++ b/pubsub/integration_test.go
@@ -1270,6 +1270,7 @@ func TestIntegration_OrderedKeys_JSON(t *testing.T) {
func TestIntegration_OrderedKeys_ResumePublish(t *testing.T) {
t.Skip("kokoro failing in https://github.com/googleapis/google-cloud-go/issues/1850")
+ /*
ctx := context.Background()
client := integrationTestClient(ctx, t)
defer client.Close()
@@ -1326,6 +1327,7 @@ func TestIntegration_OrderedKeys_ResumePublish(t *testing.T) {
if r.err != nil {
t.Fatalf("got error while publishing message: %v", r.err)
}
+ */
}
func TestIntegration_CreateSubscription_DeadLetterPolicy(t *testing.T) {
|
