Show pending activitties as History events

client/routes/workflow/helpers/get-events-from-pending-activity.js

@@ -0,0 +1,18 @@
+const getEventsFromPendingActivity = (activities, idOffset) => {
+  if (!activities) {
+    return [];
+  }
+
+  if (Number.isInteger(idOffset)) {
+    idOffset = Number(idOffset);
+  }
+
+  return activities.map((a, i) => ({
+    details: a,
+    eventId: idOffset + i + 1,
+    eventTime: a.scheduledTime,
+    eventType: 'ActivityTaskStarted',
+  }));
+};
+
+export default getEventsFromPendingActivity;

client/routes/workflow/helpers/index.js

@@ -1,6 +1,7 @@
 export { default as getEventDetails } from './get-event-details';
 export { default as getEventFullDetails } from './get-event-full-details';
 export { default as getEventSummary } from './get-event-summary';
+export { default as getEventsFromPendingActivity } from './get-events-from-pending-activity';
 export { default as getHistoryEvents } from './get-history-events';
 export { default as getHistoryTimelineEvents } from './get-history-timeline-events';
 export { default as getSummary } from './get-summary';

client/routes/workflow/history.vue

@@ -313,6 +313,7 @@ export default {
     'runId',
     'showGraph',
     'timelineEvents',
+    'pendingEvents',
     'workflowId',
   ],
   created() {
@@ -356,8 +357,9 @@ export default {
       }.json`;
     },
     filteredEvents() {
-      const { eventId, eventType } = this;
-      const formattedEvents = this.events.map(event => ({
+      const { eventId, eventType, pendingEvents } = this;
+      const events = [...this.events, ...pendingEvents];
+      const formattedEvents = events.map(event => ({
         ...event,
         expanded: event.eventId === eventId,
       }));

client/routes/workflow/index.vue

@@ -45,6 +45,7 @@
       name="history"
       :baseAPIURL="baseAPIURL"
       :events="history.events"
+      :pendingEvents="history.pendingEvents"
       :loading="history.loading"
       :timelineEvents="history.timelineEvents"
       @onNotification="onNotification"
@@ -73,6 +74,7 @@ import {
   getHistoryEvents,
   getHistoryTimelineEvents,
   getSummary,
+  getEventsFromPendingActivity,
 } from './helpers';
 import { NOTIFICATION_TYPE_ERROR } from '~constants';
 import { getErrorMessage } from '~helpers';
@@ -92,6 +94,7 @@ export default {
 
       history: {
         events: [],
+        pendingEvents: [],
         loading: undefined,
         timelineEvents: [],
       },
@@ -225,6 +228,13 @@ export default {
           this.events = this.events.concat(events);
 
           this.history.events = getHistoryEvents(this.events);
+          this.history.pendingEvents = getHistoryEvents(
+            getEventsFromPendingActivity(
+              this.workflow.pendingActivities,
+              this.history.events.length
+            )
+          );
+
           this.history.timelineEvents = getHistoryTimelineEvents(
             this.history.events
           );