@@ -236,32 +236,25 @@ def _peers_state(self) -> DPBenchmarkLifecycleState | None:
236
236
@property
237
237
def status (self ) -> StatusBase :
238
238
"""Return the status of the benchmark."""
239
- if self .current () == DPBenchmarkLifecycleState .UNSET :
240
- return WaitingStatus ("Benchmark is unset" )
241
-
242
- if self .current () == DPBenchmarkLifecycleState .PREPARING :
243
- return MaintenanceStatus ("Preparing the benchmark" )
244
-
245
- if self .current () == DPBenchmarkLifecycleState .AVAILABLE :
246
- return WaitingStatus ("Benchmark prepared: call run to start" )
247
-
248
- if self .current () == DPBenchmarkLifecycleState .RUNNING :
249
- return ActiveStatus ("Benchmark is running" )
250
-
251
- if self .current () == DPBenchmarkLifecycleState .FAILED :
252
- return BlockedStatus ("Benchmark failed execution" )
253
-
254
- if self .current () == DPBenchmarkLifecycleState .COLLECTING :
255
- return ActiveStatus ("Benchmark is collecting data" )
256
-
257
- if self .current () == DPBenchmarkLifecycleState .UPLOADING :
258
- return ActiveStatus ("Benchmark is uploading data" )
259
-
260
- if self .current () == DPBenchmarkLifecycleState .FINISHED :
261
- return ActiveStatus ("Benchmark finished" )
262
-
263
- # if self.current() == DPBenchmarkLifecycleState.STOPPED:
264
- return WaitingStatus ("Benchmark is stopped" )
239
+ match self .current ():
240
+ case DPBenchmarkLifecycleState .UNSET :
241
+ return WaitingStatus ("Benchmark is unset" )
242
+ case DPBenchmarkLifecycleState .PREPARING :
243
+ return MaintenanceStatus ("Preparing the benchmark" )
244
+ case DPBenchmarkLifecycleState .AVAILABLE :
245
+ return WaitingStatus ("Benchmark prepared: call run to start" )
246
+ case DPBenchmarkLifecycleState .RUNNING :
247
+ return ActiveStatus ("Benchmark is running" )
248
+ case DPBenchmarkLifecycleState .FAILED :
249
+ return BlockedStatus ("Benchmark failed execution" )
250
+ case DPBenchmarkLifecycleState .COLLECTING :
251
+ return ActiveStatus ("Benchmark is collecting data" )
252
+ case DPBenchmarkLifecycleState .UPLOADING :
253
+ return ActiveStatus ("Benchmark is uploading data" )
254
+ case DPBenchmarkLifecycleState .FINISHED :
255
+ return ActiveStatus ("Benchmark finished" )
256
+ case _:
257
+ return WaitingStatus ("Benchmark is stopped" )
265
258
266
259
def _compare_lifecycle_states ( # noqa: C901
267
260
self , neighbor : DPBenchmarkLifecycleState , this : DPBenchmarkLifecycleState
@@ -275,23 +268,24 @@ def _compare_lifecycle_states( # noqa: C901
275
268
return 0
276
269
277
270
def _get_value (phase : DPBenchmarkLifecycleState ) -> int : # noqa: C901
278
- if phase == DPBenchmarkLifecycleState .UNSET :
279
- return 0
280
- if phase == DPBenchmarkLifecycleState .PREPARING :
281
- return 1
282
- if phase == DPBenchmarkLifecycleState .AVAILABLE :
283
- return 2
284
- if phase == DPBenchmarkLifecycleState .RUNNING :
285
- return 3
286
- if phase == DPBenchmarkLifecycleState .FAILED :
287
- return 4
288
- if phase == DPBenchmarkLifecycleState .COLLECTING :
289
- return 5
290
- if phase == DPBenchmarkLifecycleState .UPLOADING :
291
- return 6
292
- if phase == DPBenchmarkLifecycleState .FINISHED :
293
- return 7
294
- if phase == DPBenchmarkLifecycleState .STOPPED :
295
- return 8
271
+ match phase :
272
+ case DPBenchmarkLifecycleState .UNSET :
273
+ return 0
274
+ case DPBenchmarkLifecycleState .PREPARING :
275
+ return 1
276
+ case DPBenchmarkLifecycleState .AVAILABLE :
277
+ return 2
278
+ case DPBenchmarkLifecycleState .RUNNING :
279
+ return 3
280
+ case DPBenchmarkLifecycleState .FAILED :
281
+ return 4
282
+ case DPBenchmarkLifecycleState .COLLECTING :
283
+ return 5
284
+ case DPBenchmarkLifecycleState .UPLOADING :
285
+ return 6
286
+ case DPBenchmarkLifecycleState .FINISHED :
287
+ return 7
288
+ case DPBenchmarkLifecycleState .STOPPED :
289
+ return 8
296
290
297
291
return _get_value (neighbor ) - _get_value (this )
0 commit comments