Skip to content

Commit 820798a

Browse files
authored
[Executor]Update graph test case and delete test_attention (#3257)
* 1.update graph test case 2.delete test_attention * code style * delete print
1 parent 0074b42 commit 820798a

File tree

4 files changed

+282
-438
lines changed

4 files changed

+282
-438
lines changed

test/graph_optimization/test_cuda_graph.py

Lines changed: 0 additions & 134 deletions
This file was deleted.
Lines changed: 168 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,168 @@
1+
"""
2+
# Copyright (c) 2025 PaddlePaddle Authors. All Rights Reserved.
3+
#
4+
# Licensed under the Apache License, Version 2.0 (the "License");
5+
# you may not use this file except in compliance with the License.
6+
# You may obtain a copy of the License at
7+
#
8+
# http://www.apache.org/licenses/LICENSE-2.0
9+
#
10+
# Unless required by applicable law or agreed to in writing, software
11+
# distributed under the License is distributed on an "AS IS" BASIS,
12+
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
# See the License for the specific language governing permissions and
14+
# limitations under the License.
15+
"""
16+
17+
import paddle
18+
19+
from fastdeploy.config import FDConfig, GraphOptimizationConfig, ParallelConfig
20+
from fastdeploy.model_executor.forward_meta import ForwardMeta
21+
from fastdeploy.model_executor.graph_optimization.decorator import (
22+
support_graph_optimization,
23+
)
24+
25+
26+
@support_graph_optimization
27+
class TestCase1SubLayer1(paddle.nn.Layer):
28+
"""Sub layer 1 of test case 1"""
29+
30+
def __init__(self, fd_config: FDConfig, **kwargs):
31+
super().__init__()
32+
33+
def forward(self, ids_remove_padding, forward_meta: ForwardMeta):
34+
"""Sub layer1 forward pass"""
35+
36+
output = paddle.add(forward_meta.input_ids, forward_meta.input_ids)
37+
return output
38+
39+
def forward_correct(self, ids_remove_padding, forward_meta: ForwardMeta):
40+
"""Sub layer1 Correct forward pass"""
41+
output = paddle.add(forward_meta.input_ids, forward_meta.input_ids)
42+
return output
43+
44+
45+
class TestCase1SubLayer2(paddle.nn.Layer):
46+
""" """
47+
48+
def __init__(self, fd_config: FDConfig, **kwargs):
49+
super().__init__()
50+
51+
def forward(self, ids_remove_padding, forward_meta: ForwardMeta):
52+
"""Sub layer2 forward pass"""
53+
x = forward_meta.input_ids
54+
y = forward_meta.input_ids
55+
output = x + y
56+
return output
57+
58+
def forward_correct(self, ids_remove_padding, forward_meta: ForwardMeta):
59+
"""Sub layer2 Correct forward pass"""
60+
x = forward_meta.input_ids
61+
y = forward_meta.input_ids
62+
output = x + y
63+
return output
64+
65+
66+
@support_graph_optimization
67+
class TestCase1SubLayer3(paddle.nn.Layer):
68+
""" """
69+
70+
def __init__(self, fd_config: FDConfig, **kwargs):
71+
super().__init__()
72+
73+
def forward(self, ids_remove_padding, forward_meta: ForwardMeta):
74+
"""Sub layer3 forward pass"""
75+
output = paddle.matmul(forward_meta.input_ids, forward_meta.input_ids)
76+
return output
77+
78+
def forward_correct(self, ids_remove_padding, forward_meta: ForwardMeta):
79+
"""Sub layer3 Correct forward pass"""
80+
output = paddle.matmul(forward_meta.input_ids, forward_meta.input_ids)
81+
return output
82+
83+
84+
class TestModel1(paddle.nn.Layer):
85+
"""Tast Model"""
86+
87+
def __init__(self, fd_config: FDConfig, **kwargs):
88+
super().__init__()
89+
self.fd_config = fd_config
90+
91+
self.sublayer1 = TestCase1SubLayer1(self.fd_config)
92+
self.sublayer2 = TestCase1SubLayer2(self.fd_config)
93+
self.sublayer3 = TestCase1SubLayer3(self.fd_config)
94+
95+
self.sublayer2_output_buffer = paddle.zeros([1])
96+
97+
def forward(self, ids_remove_padding, forward_meta: ForwardMeta):
98+
"""Test model for ward pass"""
99+
# sublayer1 use cuda graph
100+
sub_meta1 = forward_meta
101+
sublayer1_output = self.sublayer1(ids_remove_padding=ids_remove_padding, forward_meta=sub_meta1)
102+
103+
# sublayer2 not use cuda garph
104+
sub_meta2 = ForwardMeta(
105+
input_ids=sublayer1_output, ids_remove_padding=sublayer1_output, step_use_cudagraph=False
106+
)
107+
sublayer2_output = self.sublayer2(ids_remove_padding=sublayer1_output, forward_meta=sub_meta2)
108+
self.sublayer2_output_buffer.copy_(sublayer2_output, False)
109+
110+
# sublayer3 use cuda graph
111+
sub_meta3 = ForwardMeta(
112+
input_ids=self.sublayer2_output_buffer,
113+
ids_remove_padding=self.sublayer2_output_buffer,
114+
step_use_cudagraph=True,
115+
)
116+
sublayer3_output = self.sublayer3(ids_remove_padding=self.sublayer2_output_buffer, forward_meta=sub_meta3)
117+
118+
return sublayer3_output
119+
120+
def forward_correct(self, ids_remove_padding, forward_meta: ForwardMeta):
121+
"""Test model for ward pass"""
122+
123+
# sublayer1 not use cuda graph
124+
sub_meta1 = forward_meta
125+
sublayer1_output = self.sublayer1.forward_correct(
126+
ids_remove_padding=ids_remove_padding, forward_meta=sub_meta1
127+
)
128+
129+
# sublayer2 not use cuda garph
130+
sub_meta2 = ForwardMeta(input_ids=sublayer1_output, ids_remove_padding=sublayer1_output)
131+
sublayer2_output = self.sublayer2.forward_correct(ids_remove_padding=sublayer1_output, forward_meta=sub_meta2)
132+
133+
# sublayer3 not use cuda graph
134+
sub_meta3 = ForwardMeta(input_ids=sublayer2_output, ids_remove_padding=sublayer2_output)
135+
sublayer3_output = self.sublayer3.forward_correct(ids_remove_padding=sublayer2_output, forward_meta=sub_meta3)
136+
137+
return sublayer3_output
138+
139+
140+
def run_test_case():
141+
"""Run test case"""
142+
# Set FastDeploy config
143+
graph_opt_config = GraphOptimizationConfig(args={})
144+
graph_opt_config.use_cudagraph = True
145+
parallel_config = ParallelConfig(args={})
146+
parallel_config.max_num_seqs = 1
147+
fd_config = FDConfig(graph_opt_config=graph_opt_config, parallel_config=parallel_config)
148+
149+
# Run Test Case1
150+
test_model1 = TestModel1(fd_config=fd_config)
151+
input_tensor1 = paddle.ones([1])
152+
forward_meta1 = ForwardMeta(input_ids=input_tensor1, ids_remove_padding=input_tensor1, step_use_cudagraph=True)
153+
154+
# Triger Capture
155+
_ = test_model1(ids_remove_padding=input_tensor1, forward_meta=forward_meta1)
156+
157+
# Reaplay
158+
_ = test_model1(ids_remove_padding=input_tensor1, forward_meta=forward_meta1)
159+
output1 = test_model1(ids_remove_padding=input_tensor1, forward_meta=forward_meta1)
160+
161+
# Corrent output
162+
output1_correct = test_model1.forward_correct(ids_remove_padding=input_tensor1, forward_meta=forward_meta1)
163+
164+
assert output1 == output1_correct
165+
166+
167+
if __name__ == "__main__":
168+
run_test_case()

0 commit comments

Comments
 (0)