diff --git a/test/nexus_test.go b/test/nexus_test.go index f08925c2c..4b84f4c19 100644 --- a/test/nexus_test.go +++ b/test/nexus_test.go @@ -27,7 +27,6 @@ import ( "errors" "fmt" "net/http" - "os" "slices" "testing" "time" @@ -213,9 +212,6 @@ var workflowOp = temporalnexus.NewWorkflowRunOperation( ) func TestNexusSyncOperation(t *testing.T) { - if os.Getenv("DISABLE_NEXUS_TESTS") != "" { - t.SkipNow() - } ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) defer cancel() @@ -335,9 +331,6 @@ func TestNexusSyncOperation(t *testing.T) { } func TestNexusWorkflowRunOperation(t *testing.T) { - if os.Getenv("DISABLE_NEXUS_TESTS") != "" { - t.SkipNow() - } ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) defer cancel() tc := newTestContext(t, ctx) @@ -376,9 +369,6 @@ func TestNexusWorkflowRunOperation(t *testing.T) { } func TestSyncOperationFromWorkflow(t *testing.T) { - if os.Getenv("DISABLE_NEXUS_TESTS") != "" { - t.SkipNow() - } ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) defer cancel() tc := newTestContext(t, ctx) @@ -494,9 +484,6 @@ func TestSyncOperationFromWorkflow(t *testing.T) { } func TestAsyncOperationFromWorkflow(t *testing.T) { - if os.Getenv("DISABLE_NEXUS_TESTS") != "" { - t.SkipNow() - } ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) defer cancel() tc := newTestContext(t, ctx) @@ -662,9 +649,6 @@ func TestAsyncOperationFromWorkflow(t *testing.T) { } func TestReplay(t *testing.T) { - if os.Getenv("DISABLE_NEXUS_TESTS") != "" { - t.SkipNow() - } ctx, cancel := context.WithTimeout(context.Background(), time.Second*10) defer cancel() tc := newTestContext(t, ctx) @@ -1034,9 +1018,6 @@ func (i *nexusInterceptor) ExecuteNexusOperation( } func TestInterceptors(t *testing.T) { - if os.Getenv("DISABLE_NEXUS_TESTS") != "" { - t.SkipNow() - } ctx, cancel := context.WithTimeout(context.Background(), time.Second*30) defer cancel() tc := newTestContext(t, ctx)