From 3d2feaeecc24dde77ebd214ce9820fad86c560dd Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Sat, 26 Nov 2022 09:19:26 +0800
Subject: [PATCH] update from dtm to version v1.16.5

---
 workflow/workflow.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/workflow/workflow.go b/workflow/workflow.go
index 216fddc..b43ad53 100644
--- a/workflow/workflow.go
+++ b/workflow/workflow.go
@@ -228,6 +228,9 @@ func (wf *Workflow) DoXa(dbConf dtmcli.DBConf, fn func(db *sql.DB) ([]byte, erro
 func Interceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
 	logger.Debugf("grpc client calling: %s%s %v", cc.Target(), method, dtmimp.MustMarshalString(req))
 	wf := ctx.Value(wfMeta{}).(*Workflow)
+	if wf == nil {
+		return nil
+	}
 
 	origin := func() error {
 		ctx1 := dtmgimp.TransInfo2Ctx(ctx, wf.Gid, wf.TransType, wf.currentBranch, wf.currentOp, wf.Dtm)