Browse Source

Merge pull request #391 from ostafen/fix/workflow-interceptor

Fix worflow conversion
pull/393/head v1.16.9
yedf2 3 years ago
committed by GitHub
parent
commit
be759b9f05
No known key found for this signature in database GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      client/workflow/workflow.go

2
client/workflow/workflow.go

@ -227,7 +227,7 @@ func (wf *Workflow) DoXa(dbConf dtmcli.DBConf, fn func(db *sql.DB) ([]byte, erro
// Interceptor is the middleware for workflow to capture grpc call result
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)
wf, _ := ctx.Value(wfMeta{}).(*Workflow)
if wf == nil {
return nil
}

Loading…
Cancel
Save