Fix function test timeout doesnt works (#1539)
This commit is contained in:
@@ -24,6 +24,7 @@ import (
|
|||||||
"net/url"
|
"net/url"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
|
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||||
@@ -95,8 +96,16 @@ func (opts *TestSubCommand) do(input cli.Input) error {
|
|||||||
functionUrl.RawQuery = query.Encode()
|
functionUrl.RawQuery = query.Encode()
|
||||||
}
|
}
|
||||||
|
|
||||||
ctx, closeCtx := context.WithTimeout(context.Background(), input.Duration(flagkey.FnTestTimeout))
|
var ctx context.Context
|
||||||
defer closeCtx()
|
|
||||||
|
testTimeout := input.Duration(flagkey.FnTestTimeout)
|
||||||
|
if testTimeout <= 0*time.Second {
|
||||||
|
ctx = context.Background()
|
||||||
|
} else {
|
||||||
|
var closeCtx context.CancelFunc
|
||||||
|
ctx, closeCtx = context.WithTimeout(context.Background(), input.Duration(flagkey.FnTestTimeout))
|
||||||
|
defer closeCtx()
|
||||||
|
}
|
||||||
|
|
||||||
resp, err := doHTTPRequest(ctx, functionUrl.String(),
|
resp, err := doHTTPRequest(ctx, functionUrl.String(),
|
||||||
input.StringSlice(flagkey.FnTestHeader),
|
input.StringSlice(flagkey.FnTestHeader),
|
||||||
|
|||||||
Reference in New Issue
Block a user