func (wh *WorkflowHandler) ListTaskListPartitions(
	ctx context.Context,
	request *types.ListTaskListPartitionsRequest,
) (resp *types.ListTaskListPartitionsResponse, retError error) {
	defer log.CapturePanic(wh.GetLogger(), &retError)

	scope, sw := wh.startRequestProfileWithDomain(ctx, metrics.FrontendListTaskListPartitionsScope, request)
	defer sw.Stop()

	if wh.isShuttingDown() {
		return nil, errShuttingDown
	}

	if request == nil {
		return nil, wh.error(errRequestNotSet, scope)
	}

	if request.GetDomain() == "" {
		return nil, wh.error(errDomainNotSet, scope)
	}

	if ok := wh.allow(true, request); !ok {
		return nil, wh.error(createServiceBusyError(), scope)
	}

	if err := wh.validateTaskList(request.TaskList, scope, request.GetDomain()); err != nil {
		return nil, wh.error(err, scope)
	}

	resp, err := wh.GetMatchingClient().ListTaskListPartitions(ctx, &types.MatchingListTaskListPartitionsRequest{
		Domain:   request.Domain,
		TaskList: request.TaskList,
	})
	return resp, err
}
// ListTaskListPartitions returns all the partition and host for a taskList
ListTaskListPartitions returns all the partition and host for a taskList
// ListTaskListPartitions returns all the partition and host for a taskList
func (wh *WorkflowHandler) ListTaskListPartitions(
	ctx context.Context,
	request *types.ListTaskListPartitionsRequest,
) (resp *types.ListTaskListPartitionsResponse, retError error) {
	defer log.CapturePanic(wh.GetLogger(), &retError)
	scope, sw := wh.startRequestProfileWithDomain(ctx, metrics.FrontendListTaskListPartitionsScope, request)
	defer sw.Stop()
	if wh.isShuttingDown() {
		return nil, errShuttingDown
	}
	if request == nil {
		return nil, wh.error(errRequestNotSet, scope)
	}
	if request.GetDomain() == "" {
		return nil, wh.error(errDomainNotSet, scope)
	}
	if ok := wh.allow(true, request); !ok {
		return nil, wh.error(createServiceBusyError(), scope)
	}
	if err := wh.validateTaskList(request.TaskList, scope, request.GetDomain()); err != nil {
		return nil, wh.error(err, scope)
	}
	resp, err := wh.GetMatchingClient().ListTaskListPartitions(ctx, &types.MatchingListTaskListPartitionsRequest{
		Domain:   request.Domain,
		TaskList: request.TaskList,
	})
	return resp, err
}
func ( wh * WorkflowHandler ) ListTaskListPartitions ( ctx context . Context , request * types . ListTaskListPartitionsRequest , ) ( resp * types . ListTaskListPartitionsResponse , retError error ) { defer log . CapturePanic ( wh . GetLogger ( ) , & retError ) scope , sw := wh . startRequestProfileWithDomain ( ctx , metrics . FrontendListTaskListPartitionsScope , request ) defer sw . Stop ( ) if wh . isShuttingDown ( ) { return nil , errShuttingDown } if request == nil { return nil , wh . error ( errRequestNotSet , scope ) } if request . GetDomain ( ) == " " { return nil , wh . error ( errDomainNotSet , scope ) } if ok := wh . allow ( true , request ) ; ! ok { return nil , wh . error ( createServiceBusyError ( ) , scope ) } if err := wh . validateTaskList ( request . TaskList , scope , request . GetDomain ( ) ) ; err != nil { return nil , wh . error ( err , scope ) } resp , err := wh . GetMatchingClient ( ) . ListTaskListPartitions ( ctx , & types . MatchingListTaskListPartitionsRequest { Domain : request . Domain , TaskList : request . TaskList , } ) return resp , err }
ListTaskListPartitions returns all the partition and host for a taskList
ListTaskListPartitions returns all the partition and host for a taskList