@@ -644,6 +644,7 @@ class PipelineRunAPISerializer(serializers.HyperlinkedModelSerializer):
644
644
status = serializers .SerializerMethodField ()
645
645
execution_time = serializers .SerializerMethodField ()
646
646
log = serializers .SerializerMethodField ()
647
+ execution_time = serializers .SerializerMethodField ()
647
648
648
649
class Meta :
649
650
model = PipelineRun
@@ -666,7 +667,7 @@ def get_status(self, run):
666
667
667
668
def get_execution_time (self , run ):
668
669
if run .execution_time :
669
- return round (run .execution_time , 2 )
670
+ return f" { round (run .execution_time , 2 )} s"
670
671
671
672
def get_log (self , run ):
672
673
"""Return only last 5000 character of log."""
@@ -675,10 +676,13 @@ def get_log(self, run):
675
676
676
677
class PipelineScheduleAPISerializer (serializers .HyperlinkedModelSerializer ):
677
678
url = serializers .HyperlinkedIdentityField (
678
- view_name = "schedule-detail" , lookup_field = "pipeline_id"
679
+ view_name = "schedule-detail" ,
680
+ lookup_field = "pipeline_id" ,
679
681
)
680
682
latest_run = serializers .SerializerMethodField ()
681
683
next_run_date = serializers .SerializerMethodField ()
684
+ run_interval = serializers .SerializerMethodField ()
685
+ execution_timeout = serializers .SerializerMethodField ()
682
686
683
687
class Meta :
684
688
model = PipelineSchedule
@@ -703,6 +707,12 @@ def get_latest_run(self, schedule):
703
707
return PipelineRunAPISerializer (latest ).data
704
708
return None
705
709
710
+ def get_run_interval (self , schedule ):
711
+ return f"{ schedule .run_interval } hr"
712
+
713
+ def get_execution_timeout (self , schedule ):
714
+ return f"{ schedule .execution_timeout } hr"
715
+
706
716
707
717
class PipelineScheduleCreateSerializer (serializers .ModelSerializer ):
708
718
class Meta :
0 commit comments