Added sleep between data processing ingestion and KPI processing (#8876)

This commit is contained in:
Teddy 2022-11-21 07:28:15 +01:00 committed by GitHub
parent 997d3dc57d
commit 89348b8622
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -19,6 +19,7 @@ Workflow definition for the ORM Profiler.
from __future__ import annotations
import time
import traceback
from datetime import datetime
from typing import Optional, Union, cast
@ -266,6 +267,7 @@ class DataInsightWorkflow:
logger.info("Data processor finished running")
logger.info("Sleeping for 1 second. Waiting for ES data to be indexed.")
time.sleep(1)
logger.info("Starting KPI runner")
self._execute_kpi_runner()
logger.info("KPI runner finished running")