// OperateSchema operates schema for an upstream table.
OperateSchema operates schema for an upstream table.
// OperateSchema operates schema for an upstream table .
func (w *SourceWorker) OperateSchema(ctx context.Context, req *pb.OperateWorkerSchemaRequest) (schema string, err error) {
	w.Lock()
	defer w.Unlock()
	if w.closed.Load() {
		return "", terror.ErrWorkerAlreadyClosed.Generate()
	}
	st := w.subTaskHolder.findSubTask(req.Task)
	if st == nil {
		return "", terror.ErrWorkerSubTaskNotFound.Generate(req.Task)
	}
	return st.OperateSchema(ctx, req)
}
func ( w * SourceWorker ) OperateSchema ( ctx context . Context , req * pb . OperateWorkerSchemaRequest ) ( schema string , err error ) { w . Lock ( ) defer w . Unlock ( ) if w . closed . Load ( ) { return " " , terror . ErrWorkerAlreadyClosed . Generate ( ) } st := w . subTaskHolder . findSubTask ( req . Task ) if st == nil { return " " , terror . ErrWorkerSubTaskNotFound . Generate ( req . Task ) } return st . OperateSchema ( ctx , req ) }
OperateSchema operates schema for an upstream table.
OperateSchema operates schema for an upstream table .