File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
verl/single_controller/base Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -71,7 +71,7 @@ def init_predefined_execute_mode():
7171init_predefined_execute_mode ()
7272
7373
74- def _balance_data_proto (data_proto , chunks , model_config = None ):
74+ def _balance_data_proto (data_proto , chunks ):
7575 if (
7676 not isinstance (data_proto , DataProtoFuture )
7777 and data_proto .batch is not None
@@ -121,7 +121,7 @@ def _padding_and_split_data(obj, chunks):
121121 f"expecting all arg share same length of { data_proto_len } , but got { len (obj )} "
122122 )
123123 obj .padding (padding_size = padding_size )
124- return _balance_data_proto (obj , chunks )
124+ return _balance_data_proto (obj , chunks ). chunk ( chunks = chunks )
125125
126126 splitted_args = [_padding_and_split_data (arg , chunks ) for arg in args ]
127127 splitted_kwargs = {key : _padding_and_split_data (val , chunks ) for key , val in kwargs .items ()}
You can’t perform that action at this time.
0 commit comments