Skip to content

Commit 9a10f7f

Browse files
committed
Skip SQS and IronMQ tests
1 parent d17f72c commit 9a10f7f

File tree

4 files changed

+57
-6
lines changed

4 files changed

+57
-6
lines changed

.github/workflows/build.yml

+3-3
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,9 @@ name: Go
22

33
on:
44
push:
5-
branches: [master]
5+
branches: [v3]
66
pull_request:
7-
branches: [master]
7+
branches: [v3]
88

99
jobs:
1010
build:
@@ -30,4 +30,4 @@ jobs:
3030
uses: actions/checkout@v2
3131

3232
- name: Test
33-
run: go test memqueue
33+
run: make test

Makefile

+2-3
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,5 @@ all:
66
go test ./... -run=NONE -bench=. -benchmem
77
golangci-lint run
88

9-
tag:
10-
git tag $(VERSION)
11-
git tag extra/taskqotel/$(VERSION)
9+
test:
10+
go test

azsqs_test.go

+28
Original file line numberDiff line numberDiff line change
@@ -26,85 +26,113 @@ func azsqsFactory() taskq.Factory {
2626
}
2727

2828
func TestSQSConsumer(t *testing.T) {
29+
t.Skip()
30+
2931
testConsumer(t, azsqsFactory(), &taskq.QueueOptions{
3032
Name: queueName("sqs-consumer"),
3133
})
3234
}
3335

3436
func TestSQSUnknownTask(t *testing.T) {
37+
t.Skip()
38+
3539
testUnknownTask(t, azsqsFactory(), &taskq.QueueOptions{
3640
Name: queueName("sqs-unknown-task"),
3741
})
3842
}
3943

4044
func TestSQSFallback(t *testing.T) {
45+
t.Skip()
46+
4147
testFallback(t, azsqsFactory(), &taskq.QueueOptions{
4248
Name: queueName("sqs-fallback"),
4349
})
4450
}
4551

4652
func TestSQSDelay(t *testing.T) {
53+
t.Skip()
54+
4755
testDelay(t, azsqsFactory(), &taskq.QueueOptions{
4856
Name: queueName("sqs-delay"),
4957
})
5058
}
5159

5260
func TestSQSRetry(t *testing.T) {
61+
t.Skip()
62+
5363
testRetry(t, azsqsFactory(), &taskq.QueueOptions{
5464
Name: queueName("sqs-retry"),
5565
})
5666
}
5767

5868
func TestSQSNamedMessage(t *testing.T) {
69+
t.Skip()
70+
5971
testNamedMessage(t, azsqsFactory(), &taskq.QueueOptions{
6072
Name: queueName("sqs-named-message"),
6173
})
6274
}
6375

6476
func TestSQSCallOnce(t *testing.T) {
77+
t.Skip()
78+
6579
testCallOnce(t, azsqsFactory(), &taskq.QueueOptions{
6680
Name: queueName("sqs-call-once"),
6781
})
6882
}
6983

7084
func TestSQSLen(t *testing.T) {
85+
t.Skip()
86+
7187
testLen(t, azsqsFactory(), &taskq.QueueOptions{
7288
Name: queueName("sqs-queue-len"),
7389
})
7490
}
7591

7692
func TestSQSRateLimit(t *testing.T) {
93+
t.Skip()
94+
7795
testRateLimit(t, azsqsFactory(), &taskq.QueueOptions{
7896
Name: queueName("sqs-rate-limit"),
7997
})
8098
}
8199

82100
func TestSQSErrorDelay(t *testing.T) {
101+
t.Skip()
102+
83103
testErrorDelay(t, azsqsFactory(), &taskq.QueueOptions{
84104
Name: queueName("sqs-delayer"),
85105
})
86106
}
87107

88108
func TestSQSWorkerLimit(t *testing.T) {
109+
t.Skip()
110+
89111
testWorkerLimit(t, azsqsFactory(), &taskq.QueueOptions{
90112
Name: queueName("sqs-worker-limit"),
91113
})
92114
}
93115

94116
func TestSQSInvalidCredentials(t *testing.T) {
117+
t.Skip()
118+
95119
man := azsqs.NewFactory(awsSQS(), "123")
96120
testInvalidCredentials(t, man, &taskq.QueueOptions{
97121
Name: queueName("sqs-invalid-credentials"),
98122
})
99123
}
100124

101125
func TestSQSBatchConsumerSmallMessage(t *testing.T) {
126+
t.Skip()
127+
102128
testBatchConsumer(t, azsqsFactory(), &taskq.QueueOptions{
103129
Name: queueName("sqs-batch-consumer-small-message"),
104130
}, 100)
105131
}
106132

107133
func TestSQSBatchConsumerLarge(t *testing.T) {
134+
t.Skip()
135+
108136
testBatchConsumer(t, azsqsFactory(), &taskq.QueueOptions{
109137
Name: queueName("sqs-batch-processor-large-message"),
110138
}, 64000)

ironmq_test.go

+24
Original file line numberDiff line numberDiff line change
@@ -15,72 +15,96 @@ func ironmqFactory() taskq.Factory {
1515
}
1616

1717
func TestIronmqConsumer(t *testing.T) {
18+
t.Skip()
19+
1820
testConsumer(t, ironmqFactory(), &taskq.QueueOptions{
1921
Name: queueName("ironmq-consumer"),
2022
})
2123
}
2224

2325
func TestIronmqUnknownTask(t *testing.T) {
26+
t.Skip()
27+
2428
testUnknownTask(t, ironmqFactory(), &taskq.QueueOptions{
2529
Name: queueName("ironmq-unknown-task"),
2630
})
2731
}
2832

2933
func TestIronmqFallback(t *testing.T) {
34+
t.Skip()
35+
3036
testFallback(t, ironmqFactory(), &taskq.QueueOptions{
3137
Name: queueName("ironmq-fallback"),
3238
})
3339
}
3440

3541
func TestIronmqDelay(t *testing.T) {
42+
t.Skip()
43+
3644
testDelay(t, ironmqFactory(), &taskq.QueueOptions{
3745
Name: queueName("ironmq-delay"),
3846
})
3947
}
4048

4149
func TestIronmqRetry(t *testing.T) {
50+
t.Skip()
51+
4252
testRetry(t, ironmqFactory(), &taskq.QueueOptions{
4353
Name: queueName("ironmq-retry"),
4454
})
4555
}
4656

4757
func TestIronmqNamedMessage(t *testing.T) {
58+
t.Skip()
59+
4860
testNamedMessage(t, ironmqFactory(), &taskq.QueueOptions{
4961
Name: queueName("ironmq-named-message"),
5062
})
5163
}
5264

5365
func TestIronmqCallOnce(t *testing.T) {
66+
t.Skip()
67+
5468
testCallOnce(t, ironmqFactory(), &taskq.QueueOptions{
5569
Name: queueName("ironmq-call-once"),
5670
})
5771
}
5872

5973
func TestIronmqLen(t *testing.T) {
74+
t.Skip()
75+
6076
testLen(t, ironmqFactory(), &taskq.QueueOptions{
6177
Name: queueName("ironmq-len"),
6278
})
6379
}
6480

6581
func TestIronmqRateLimit(t *testing.T) {
82+
t.Skip()
83+
6684
testRateLimit(t, ironmqFactory(), &taskq.QueueOptions{
6785
Name: queueName("ironmq-rate-limit"),
6886
})
6987
}
7088

7189
func TestIronmqErrorDelay(t *testing.T) {
90+
t.Skip()
91+
7292
testErrorDelay(t, ironmqFactory(), &taskq.QueueOptions{
7393
Name: queueName("ironmq-delayer"),
7494
})
7595
}
7696

7797
func TestIronmqWorkerLimit(t *testing.T) {
98+
t.Skip()
99+
78100
testWorkerLimit(t, ironmqFactory(), &taskq.QueueOptions{
79101
Name: queueName("ironmq-worker-limit"),
80102
})
81103
}
82104

83105
func TestIronmqInvalidCredentials(t *testing.T) {
106+
t.Skip()
107+
84108
settings := &iron_config.Settings{
85109
ProjectId: "123",
86110
}

0 commit comments

Comments
 (0)