File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2262,6 +2262,10 @@ def requeue(self):
22622262class PipelineSchedule (models .Model ):
22632263 """The Database representation of a pipeline schedule."""
22642264
2265+ class ExecutionPriority (models .IntegerChoices ):
2266+ HIGH = 1 , "high"
2267+ DEFAULT = 2 , "default"
2268+
22652269 pipeline_id = models .CharField (
22662270 max_length = 600 ,
22672271 help_text = ("Identify a registered Pipeline class." ),
@@ -2306,6 +2310,14 @@ class PipelineSchedule(models.Model):
23062310 help_text = ("Number of hours to wait between run of this pipeline." ),
23072311 )
23082312
2313+ run_priority = models .IntegerField (
2314+ null = False ,
2315+ blank = False ,
2316+ choices = ExecutionPriority .choices ,
2317+ default = ExecutionPriority .DEFAULT ,
2318+ help_text = ("Select the pipeline execution priority" ),
2319+ )
2320+
23092321 schedule_work_id = models .CharField (
23102322 max_length = 255 ,
23112323 unique = True ,
You can’t perform that action at this time.
0 commit comments