Skip to content

Commit f0503ed

Browse files
committed
[core] Log when DD scheduler connected
1 parent c320e03 commit f0503ed

2 files changed

Lines changed: 2 additions & 0 deletions

File tree

core/integration/ddsched/client.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ func NewClient(cxt context.Context, cancel context.CancelFunc, endpoint string)
5454
cancel()
5555
return nil
5656
}
57+
log.Debug("DD scheduler client connected")
5758

5859
client := &RpcClient {
5960
DataDistributionControlClient: ddpb.NewDataDistributionControlClient(conn),

core/integration/ddsched/plugin.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,7 @@ func (p *Plugin) Init(_ string) error {
8787
if p.ddSchedClient == nil {
8888
return fmt.Errorf("failed to connect to DD scheduler service on %s", viper.GetString("ddSchedulerEndpoint"))
8989
}
90+
log.Debug("DD scheduler plugin ready")
9091
}
9192
return nil
9293
}

0 commit comments

Comments
 (0)