[dy] Expire certain pipeline runs (mage-ai#4727)

mage_ai/api/resources/PipelineRunResource.py

@@ -12,7 +12,7 @@
     ScheduleStatus,
     ScheduleType,
 )
-from mage_ai.orchestration.db import safe_db_query
+from mage_ai.orchestration.db import db_connection, safe_db_query
 from mage_ai.orchestration.db.models.schedules import (
     BlockRun,
     PipelineRun,
@@ -241,6 +241,15 @@ async def process_collection(self, query_arg, meta, user, **kwargs):
         has_next = results_size > limit
         final_end_idx = results_size - 1 if has_next else results_size
 
+        # Expire pipeline runs that are in progress so that the latest status is returned
+        # the next time they are fetched.
+        for run in results:
+            if run.status in (
+                PipelineRun.PipelineRunStatus.RUNNING,
+                PipelineRun.PipelineRunStatus.INITIAL,
+            ):
+                db_connection.session.expire(run)
+
         result_set = self.build_result_set(
             results[0:final_end_idx],
             user,

mage_ai/frontend/components/Triggers/Detail/index.tsx

@@ -162,10 +162,12 @@ function TriggerDetail({
     mutate: fetchPipelineRuns,
   } = api.pipeline_runs.pipeline_schedules.list(
     pipelineScheduleID,
-    pipelineRunsRequestQuery, {
-    refreshInterval: 3000,
-    revalidateOnFocus: true,
-  });
+    pipelineRunsRequestQuery,
+    {
+      refreshInterval: 3000,
+      revalidateOnFocus: true,
+    },
+  );
   const pipelineRuns = useMemo(() => dataPipelineRuns?.pipeline_runs || [], [dataPipelineRuns]);
   const totalRuns = useMemo(() => dataPipelineRuns?.metadata?.count || [], [dataPipelineRuns]);