Poll for job status on results page

elastic · Oct 8, 2019 · 43c2edf · 43c2edf
1 parent 5eeefce
commit 43c2edf
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/...ck/legacy/plugins/infra/public/containers/logs/log_analysis/log_analysis_status_state.tsx b/...ck/legacy/plugins/infra/public/containers/logs/log_analysis/log_analysis_status_state.tsx
@@ -92,7 +92,7 @@ function statusReducer(state: StatusReducerState, action: StatusReducerAction):
     case 'fetchingJobStatuses': {
       return {
         ...state,
-        setupStatus: 'initializing',
+        setupStatus: state.setupStatus === 'unknown' ? 'initializing' : state.setupStatus,
       };
     }
     case 'fetchedJobStatuses': {

diff --git a/x-pack/legacy/plugins/infra/public/pages/logs/analysis/page_results_content.tsx b/x-pack/legacy/plugins/infra/public/pages/logs/analysis/page_results_content.tsx
@@ -17,21 +17,25 @@ import {
 } from '@elastic/eui';
 import { i18n } from '@kbn/i18n';
 import moment from 'moment';
-import React, { useCallback, useMemo, useState } from 'react';
+import React, { useCallback, useContext, useMemo, useState } from 'react';
 
 import euiStyled from '../../../../../../common/eui_styled_components';
 import { TimeRange } from '../../../../common/http_api/shared/time_range';
 import { bucketSpan } from '../../../../common/log_analysis';
 import { LoadingPage } from '../../../components/loading_page';
 import {
+  LogAnalysisJobs,
   StringTimeRange,
   useLogAnalysisResults,
   useLogAnalysisResultsUrlState,
 } from '../../../containers/logs/log_analysis';
+import { useInterval } from '../../../hooks/use_interval';
 import { useTrackPageview } from '../../../hooks/use_track_metric';
 import { FirstUseCallout } from './first_use';
 import { LogRateResults } from './sections/log_rate';
 
+const JOB_STATUS_POLLING_INTERVAL = 10000;
+
 export const AnalysisResultsContent = ({
   sourceId,
   isFirstUse,
@@ -120,6 +124,12 @@ export const AnalysisResultsContent = ({
     [setAutoRefresh]
   );
 
+  const { fetchJobStatus, jobStatus } = useContext(LogAnalysisJobs.Context);
+
+  useInterval(() => {
+    fetchJobStatus();
+  }, JOB_STATUS_POLLING_INTERVAL);
+
   return (
     <>
       {isLoading && !logEntryRate ? (