@@ -50,7 +50,6 @@ class StepTypeEnum(Enum, metaclass=DefaultEnumMeta):
50
50
51
51
CONDITION = "Condition"
52
52
CREATE_MODEL = "Model"
53
- FAIL = "Fail"
54
53
PROCESSING = "Processing"
55
54
REGISTER_MODEL = "RegisterModel"
56
55
TRAINING = "Training"
@@ -341,44 +340,3 @@ def to_request(self) -> RequestType:
341
340
property_file .expr for property_file in self .property_files
342
341
]
343
342
return request_dict
344
-
345
-
346
- class FailStep (Step ):
347
- """Pipeline step to indicate failure."""
348
-
349
- def __init__ (self , name : str = "Fail" ):
350
- """Construct a FailStep.
351
-
352
- Causes the pipeline execution to terminate in a failed state.
353
-
354
- Args:
355
- name (str): The name of the step.
356
- """
357
- super (FailStep , self ).__init__ (name , StepTypeEnum .FAIL )
358
- root_path = f"Steps.{ name } "
359
- root_prop = Properties (path = root_path )
360
- root_prop .__dict__ ["Fail" ] = Properties (f"{ root_path } .Fail" )
361
- self ._properties = root_prop
362
-
363
- @property
364
- def arguments (self ) -> RequestType :
365
- """The arguments to the particular step service call."""
366
- return {}
367
-
368
- @property
369
- def properties (self ):
370
- """The properties of the particular step."""
371
- return self ._properties
372
-
373
- def to_request (self ) -> RequestType :
374
- """Get the request structure for workflow service calls."""
375
- return {
376
- "Name" : self .name ,
377
- "Type" : self .step_type .value ,
378
- "Arguments" : self .arguments ,
379
- }
380
-
381
- @property
382
- def ref (self ) -> Dict [str , str ]:
383
- """Get a reference dict for steps"""
384
- return {"Name" : self .name }
0 commit comments