using next_dagrun_data_interval_end in next run date

Tauffer-Consulting · Mar 21, 2024 · 7d149cc · 7d149cc
1 parent d81b131
commit 7d149cc
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/rest/services/workflow_service.py b/rest/services/workflow_service.py
@@ -204,14 +204,14 @@ async def list_workflows(
                 is_paused = False
 
             if response and not is_dag_broken:
-                schedule = response.get("schedule_interval")
-                if isinstance(schedule, dict):
-                    schedule = schedule.get("value")
+                schedule = dag_data.schedule.value
+                if schedule != 'none':
+                    schedule = f"@{schedule}"
                 status = WorkflowStatus.active.value
 
                 is_paused = response.get("is_paused")
                 is_active = response.get("is_active")
-                next_dagrun = response.get("next_dagrun")
+                next_dagrun = response.get("next_dagrun_data_interval_end")
 
             data.append(
                 GetWorkflowsResponseData(