Skip to content

Commit

Permalink
More debug commit
Browse files Browse the repository at this point in the history
Signed-off-by: Lakshman <Lakshman@localhost>
  • Loading branch information
Lakshman authored and Lakshman committed Jul 29, 2024
1 parent 2d89ecf commit d963cee
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions tools/invoker/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -168,11 +168,13 @@ loop:
}

func SayHello(address, workflowID string) {
log.Debugf("In SayHello\n")
dialOptions := make([]grpc.DialOption, 0)
dialOptions = append(dialOptions, grpc.WithTransportCredentials(insecure.NewCredentials()))
if *withTracing {
dialOptions = append(dialOptions, grpc.WithStatsHandler(otelgrpc.NewClientHandler()))
}
log.Debugf("In SayHello before NewClient\n")
conn, err := grpc.NewClient(address, dialOptions...)
if err != nil {
log.Fatalf("did not connect: %v", err)
Expand All @@ -183,7 +185,7 @@ func SayHello(address, workflowID string) {

ctx, cancel := context.WithTimeout(context.Background(), grpcTimeout)
defer cancel()

log.Debugf("In SayHello before c.SayHello\n")
response, err := c.SayHello(ctx, &pb.HelloRequest{
Name: "Invoke relay",
VHiveMetadata: vhivemetadata.MakeVHiveMetadata(
Expand Down Expand Up @@ -229,7 +231,7 @@ func invokeServingFunction(endpoint *endpoint.Endpoint) {

address := fmt.Sprintf("%s:%d", endpoint.Hostname, *portFlag)
log.Debug("Invoking: ", address)

log.Debugf("In invokeServingFunction before SayHello\n")
SayHello(address, workflowIDs[endpoint])
}

Expand Down

0 comments on commit d963cee

Please sign in to comment.