Skip to content

Unimplemented desc = unknown service workflow.Workflow. #5

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
KaFski opened this issue Mar 22, 2023 · 0 comments
Open

Unimplemented desc = unknown service workflow.Workflow. #5

KaFski opened this issue Mar 22, 2023 · 0 comments

Comments

@KaFski
Copy link

KaFski commented Mar 22, 2023

Im using dtm-labs/client/workflow packaged to register gRPC workflow server in following way:

import (
	"github.com/dtm-labs/client/dtmcli"
	"github.com/dtm-labs/client/dtmgrpc/dtmgimp"
	"github.com/dtm-labs/client/workflow"
        ...
)

...

func InitDtmGrpc(grpcDtm string, host string, port int) {
	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", port))
	if err != nil {
		log.Fatal(err)
	}

	server := grpc.NewServer(grpc.UnaryInterceptor(dtmgimp.GrpcServerLog))
	workflow.InitGrpc(grpcDtm, fmt.Sprintf("%s:%d", host, port), server)
	go func() {
		if err := server.Serve(lis); err != nil {
			log.Fatal(err)
		}
	}()
}

But the DTM which calls the workflow server can't find the service as if it was unregistered.

    "log": "{\"level\":\"error\",\"ts\":\"2023-03-22T17:48:21.809Z\",\"caller\":\"dtmsvr/trans_process.go:63\",\"msg\":\"processInner got error: rpc error: code = Unimplemented desc = unknown service workflow.Workflow\",\"stacktrace\":\"github.com/dtm-labs/dtm/dtmsvr.(*TransGlobal).processInner.func1\\n\\t/app/dtm/dtmsvr/trans_process.go:63\\ngithub.com/dtm-labs/dtm/dtmsvr.(*TransGlobal).processInner\\n\\t/app/dtm/dtmsvr/trans_process.go:74\\ngithub.com/dtm-labs/dtm/dtmsvr.(*TransGlobal).process\\n\\t/app/dtm/dtmsvr/trans_process.go:45\\ngithub.com/dtm-labs/dtm/dtmsvr.(*TransGlobal).Process\\n\\t/app/dtm/dtmsvr/trans_process.go:22\\ngithub.com/dtm-labs/dtm/dtmsvr.CronTransOnce\\n\\t/app/dtm/dtmsvr/cron.go:37\\ngithub.com/dtm-labs/dtm/dtmsvr.CronExpiredTrans\\n\\t/app/dtm/dtmsvr/cron.go:45\"}\n",
    "stream": "stderr",
    "log_processed": {
        "level": "error",
        "ts": "2023-03-22T17:48:21.809Z",
        "caller": "dtmsvr/trans_process.go:63",
        "msg": "processInner got error: rpc error: code = Unimplemented desc = unknown service workflow.Workflow",
        "stacktrace": "github.com/dtm-labs/dtm/dtmsvr.(*TransGlobal).processInner.func1\n\t/app/dtm/dtmsvr/trans_process.go:63\ng.yxqyang.asia/dtm-labs/dtm/dtmsvr.(*TransGlobal).processInner\n\t/app/dtm/dtmsvr/trans_process.go:74\ng.yxqyang.asia/dtm-labs/dtm/dtmsvr.(*TransGlobal).process\n\t/app/dtm/dtmsvr/trans_process.go:45\ng.yxqyang.asia/dtm-labs/dtm/dtmsvr.(*TransGlobal).Process\n\t/app/dtm/dtmsvr/trans_process.go:22\ng.yxqyang.asia/dtm-labs/dtm/dtmsvr.CronTransOnce\n\t/app/dtm/dtmsvr/cron.go:37\ng.yxqyang.asia/dtm-labs/dtm/dtmsvr.CronExpiredTrans\n\t/app/dtm/dtmsvr/cron.go:45"
    }

I've checked the ports and connection and it seems to be fine, it's just that workflow service doesn't seem to be registered for some reason

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant