diff --git a/client/workflow/workflow.go b/client/workflow/workflow.go index 8cf59ee..ae40922 100644 --- a/client/workflow/workflow.go +++ b/client/workflow/workflow.go @@ -7,7 +7,6 @@ import ( "log" "net/http" "net/url" - "time" "github.com/dtm-labs/dtm/client/dtmcli" "github.com/dtm-labs/dtm/client/dtmcli/dtmimp" @@ -222,7 +221,6 @@ func Interceptor(ctx context.Context, method string, req, reply interface{}, cc cc.Target(), method, dtmimp.MustMarshalString(req), dtmimp.MustMarshalString(reply), err) st, _ := status.FromError(err) if st != nil && st.Code() == codes.Unavailable { - time.Sleep(1 * time.Second) err = invoker(ctx1, method, req, reply, cc, opts...) if err == nil { log.Fatalf("after manually retry, err == nil")