@@ -27,7 +27,6 @@ import (
27
27
"errors"
28
28
"fmt"
29
29
"net/http"
30
- "os"
31
30
"slices"
32
31
"testing"
33
32
"time"
@@ -213,9 +212,6 @@ var workflowOp = temporalnexus.NewWorkflowRunOperation(
213
212
)
214
213
215
214
func TestNexusSyncOperation (t * testing.T ) {
216
- if os .Getenv ("DISABLE_NEXUS_TESTS" ) != "" {
217
- t .SkipNow ()
218
- }
219
215
ctx , cancel := context .WithTimeout (context .Background (), time .Second * 5 )
220
216
defer cancel ()
221
217
@@ -335,9 +331,6 @@ func TestNexusSyncOperation(t *testing.T) {
335
331
}
336
332
337
333
func TestNexusWorkflowRunOperation (t * testing.T ) {
338
- if os .Getenv ("DISABLE_NEXUS_TESTS" ) != "" {
339
- t .SkipNow ()
340
- }
341
334
ctx , cancel := context .WithTimeout (context .Background (), time .Second * 5 )
342
335
defer cancel ()
343
336
tc := newTestContext (t , ctx )
@@ -376,9 +369,6 @@ func TestNexusWorkflowRunOperation(t *testing.T) {
376
369
}
377
370
378
371
func TestSyncOperationFromWorkflow (t * testing.T ) {
379
- if os .Getenv ("DISABLE_NEXUS_TESTS" ) != "" {
380
- t .SkipNow ()
381
- }
382
372
ctx , cancel := context .WithTimeout (context .Background (), time .Second * 5 )
383
373
defer cancel ()
384
374
tc := newTestContext (t , ctx )
@@ -494,9 +484,6 @@ func TestSyncOperationFromWorkflow(t *testing.T) {
494
484
}
495
485
496
486
func TestAsyncOperationFromWorkflow (t * testing.T ) {
497
- if os .Getenv ("DISABLE_NEXUS_TESTS" ) != "" {
498
- t .SkipNow ()
499
- }
500
487
ctx , cancel := context .WithTimeout (context .Background (), time .Second * 5 )
501
488
defer cancel ()
502
489
tc := newTestContext (t , ctx )
@@ -662,9 +649,6 @@ func TestAsyncOperationFromWorkflow(t *testing.T) {
662
649
}
663
650
664
651
func TestReplay (t * testing.T ) {
665
- if os .Getenv ("DISABLE_NEXUS_TESTS" ) != "" {
666
- t .SkipNow ()
667
- }
668
652
ctx , cancel := context .WithTimeout (context .Background (), time .Second * 10 )
669
653
defer cancel ()
670
654
tc := newTestContext (t , ctx )
@@ -1034,9 +1018,6 @@ func (i *nexusInterceptor) ExecuteNexusOperation(
1034
1018
}
1035
1019
1036
1020
func TestInterceptors (t * testing.T ) {
1037
- if os .Getenv ("DISABLE_NEXUS_TESTS" ) != "" {
1038
- t .SkipNow ()
1039
- }
1040
1021
ctx , cancel := context .WithTimeout (context .Background (), time .Second * 30 )
1041
1022
defer cancel ()
1042
1023
tc := newTestContext (t , ctx )
0 commit comments