@@ -178,25 +178,21 @@ def _get_cmd(self) -> list[str]:
178
178
'--include' , str (self .query_num ),
179
179
'--iterations' , str (self .iterations ),
180
180
'--plan' , self ._plan_path ,
181
+ '--global-timeout' , f'{ self .timeout } s' ,
181
182
'--verbose'
182
183
]
183
184
query_preffix = get_external_param ('query-prefix' , '' )
184
185
if query_preffix :
185
186
cmd += ['--query-settings' , query_preffix ]
186
187
if self .check_canonical :
187
- cmd .append ('--check-cannonical ' )
188
+ cmd .append ('--check-canonical ' )
188
189
return cmd
189
190
190
191
def _exec_cli (self ) -> None :
191
- try :
192
- process = yatest .common .process .execute (self ._get_cmd (), wait = False , check_exit_code = False )
193
- process .wait (check_exit_code = False , timeout = self .timeout )
194
- self ._process_returncode (process .returncode , process .stderr .decode ('utf-8' , 'replace' ))
195
- except (yatest .common .process .TimeoutError , yatest .common .process .ExecutionTimeoutError ):
196
- self ._process_returncode (0 , process .stderr .decode ('utf-8' , 'replace' ))
197
- self ._add_error (f'Timeout { self .timeout } s expeared.' )
192
+ process = yatest .common .process .execute (self ._get_cmd (), check_exit_code = False )
198
193
self .result .stdout = process .stdout .decode ('utf-8' , 'replace' )
199
194
self .result .stderr = process .stderr .decode ('utf-8' , 'replace' )
195
+ self ._process_returncode (process .returncode , self .result .stderr )
200
196
201
197
def process (self ) -> YdbCliHelper .WorkloadRunResult :
202
198
try :
0 commit comments