1150
}
1151
1152
>
func (s *scheduler) handleDescribeQuery() (*schedulespb.DescribeResponse, error) {
workflow.go
1153
>
// this is a query handler, don't modify s.Info directly
1154
>
infoCopy := common.CloneProto(s.Info)
1155
>
infoCopy.FutureActionTimes = s.getFutureActionTimes(false, s.tweakables.FutureActionCount)
1156
>
infoCopy.BufferSize = int64(len(s.State.BufferedStarts))
1157
>
1158
>
return &schedulespb.DescribeResponse{
1159
>
Schedule: s.Schedule,
1160
>
Info: infoCopy,
1161
>
ConflictToken: s.State.ConflictToken,
1162
>
}, nil
1163
>
}
1164
1165
func (s *scheduler) handleListMatchingTimesQuery(req *workflowservice.ListScheduleMatchingTimesRequest) (*workflowservice.ListScheduleMatchingTimesResponse, error) {