remove trigger_rule

Author: andrii-i

jupyter_scheduler/models.py

@@ -72,20 +72,6 @@ def __str__(self):
 OUTPUT_FILENAME_TEMPLATE = "{{input_filename}}-{{create_time}}"
 
 
-class TriggerRule(str, Enum):
-    ALL_SUCCESS = "all_success"
-    ALL_FAILES = "all_failed"
-    ALL_DONE = "all_done"
-    ONE_FAILED = "one_failed"
-    ONE_SUCCESS = "one_success"
-    NONE_FAILED = "none_failed"
-    NONE_SKIPPED = "none_skipped"
-    DUMMY = "dummy"
-
-    def __str__(self):
-        return self.value
-
-
 class CreateJob(BaseModel):
     """Defines the model for creating a new job"""
 
@@ -104,7 +90,6 @@ class CreateJob(BaseModel):
     package_input_folder: Optional[bool] = None
     depends_on: Optional[List[str]] = None
     workflow_id: Optional[str] = None
-    trigger_rule: Optional[TriggerRule] = None
 
     @root_validator
     def compute_input_filename(cls, values) -> Dict:
@@ -169,7 +154,6 @@ class DescribeJob(BaseModel):
     packaged_files: Optional[List[str]] = []
     depends_on: Optional[List[str]] = None
     workflow_id: Optional[str] = None
-    trigger_rule: Optional[TriggerRule] = None
 
     class Config:
         orm_mode = True
@@ -216,7 +200,6 @@ class UpdateJob(BaseModel):
     name: Optional[str] = None
     compute_type: Optional[str] = None
     depends_on: Optional[List[str]] = None
-    trigger_rule: Optional[TriggerRule] = None
 
 
 class DeleteJob(BaseModel):
@@ -239,7 +222,6 @@ class CreateJobDefinition(BaseModel):
     package_input_folder: Optional[bool] = None
     depends_on: Optional[List[str]] = None
     workflow_definition_id: Optional[str] = None
-    trigger_rule: Optional[TriggerRule] = None
 
     @root_validator
     def compute_input_filename(cls, values) -> Dict:
@@ -269,7 +251,6 @@ class DescribeJobDefinition(BaseModel):
     packaged_files: Optional[List[str]] = []
     depends_on: Optional[List[str]] = None
     workflow_definition_id: Optional[str] = None
-    trigger_rule: Optional[TriggerRule] = None
 
     class Config:
         orm_mode = True
@@ -291,7 +272,6 @@ class UpdateJobDefinition(BaseModel):
     input_uri: Optional[str] = None
     depends_on: Optional[List[str]] = None
     workflow_definition_id: Optional[str] = None
-    trigger_rule: Optional[TriggerRule] = None
 
 
 class ListJobDefinitionsQuery(BaseModel):

jupyter_scheduler/orm.py

@@ -7,7 +7,7 @@
 from sqlalchemy.orm import declarative_base, declarative_mixin, registry, sessionmaker
 from sqlalchemy.sql import text
 
-from jupyter_scheduler.models import EmailNotifications, Status, TriggerRule
+from jupyter_scheduler.models import EmailNotifications, Status
 from jupyter_scheduler.utils import get_utc_timestamp
 
 Base = declarative_base()
@@ -90,7 +90,6 @@ class CommonColumns:
     package_input_folder = Column(Boolean)
     packaged_files = Column(JsonType, default=[])
     depends_on = Column(JsonType)
-    trigger_rule = Column(String(64))
 
 
 class Job(CommonColumns, Base):