Merge pull request #469 from PrefectHQ/fix/fixed-event-polling

Fix: Use static polling interval for events

src/factories/data.ts

@@ -27,7 +27,7 @@ export async function dataFactory(runId: string, callback: DataCallback) {
 
   // todo: need a global way of stopping this when the graph is stopped
   function stop(): void {
-    clearInterval(interval)
+    clearTimeout(interval)
   }
 
   return {

src/factories/eventData.ts

@@ -1,5 +1,4 @@
 import { MaybeRefOrGetter, toValue } from 'vue'
-import { getIntervalForDataSize } from '@/factories/data'
 import { RunGraphEvent, RunGraphFetchEventsOptions } from '@/models'
 import { waitForConfig } from '@/objects/config'
 import { waitForRunData } from '@/objects/nodes'
@@ -28,13 +27,13 @@ export async function eventDataFactory(
     }
 
     if (!runGraphData.end_time) {
-      interval = setTimeout(() => start(), getIntervalForDataSize(runGraphData))
+      interval = setTimeout(() => start(), config.fetchEventsInterval)
     }
   }
 
   // todo: need a global way of stopping this when the graph is stopped
   function stop(): void {
-    clearInterval(interval)
+    clearTimeout(interval)
   }
 
   return {

src/models/RunGraph.ts

@@ -123,6 +123,7 @@ export type RunGraphConfig = {
   runId: string,
   fetch: RunGraphFetch,
   fetchEvents?: RunGraphFetchEvents,
+  fetchEventsInterval?: number,
   animationDuration?: number,
   styles?: RunGraphStyles,
   disableAnimationsThreshold?: number,

src/objects/config.ts

@@ -11,6 +11,7 @@ const defaults: Omit<RequiredGraphConfig, 'runId' | 'fetch'> = {
   disableAnimationsThreshold: 500,
   disableEdgesThreshold: 500,
   fetchEvents: () => [],
+  fetchEventsInterval: 30000,
   styles: {
     colorMode: 'dark',
     rowGap: 24,