Fixed local cluster bug and added datasource version compatibility check before importing workflows

public/pages/workflows/import_workflow/import_workflow_modal.tsx

@@ -27,6 +27,7 @@ import {
   getObjFromJsonOrYamlString,
   isValidUiWorkflow,
   isValidWorkflow,
+  isCompatibleWorkflow,
 } from '../../../utils';
 import { getCore } from '../../../services';
 import {
@@ -86,6 +87,11 @@ export function ImportWorkflowModal(props: ImportWorkflowModalProps) {
     return description.length > MAX_DESCRIPTION_LENGTH;
   }
 
+  // States for tracking workflow template compatibility with current data source version
+  const [isCompatible, setIsCompatible] = useState<boolean>(true);
+  const [inCompatibleDataSourceVersion, setInCompatibleDataSourceVersion] = useState<string | undefined>();
+
+
   // transient importing state for button state
   const [isImporting, setIsImporting] = useState<boolean>(false);
 
@@ -115,6 +121,19 @@ export function ImportWorkflowModal(props: ImportWorkflowModalProps) {
     }
   }, [fileObj]);
 
+  useEffect(() => {
+    async function checkCompatibility() {
+      if (isValidWorkflow(fileObj)) {
+        const [isCompatible, dataSourceVersion] = await isCompatibleWorkflow(fileObj, dataSourceId);
+        setIsCompatible(isCompatible);
+        if (dataSourceVersion) {
+          setInCompatibleDataSourceVersion(dataSourceVersion);
+        }
+      }
+    }
+    checkCompatibility();
+  }, [fileObj, dataSourceId]);
+
   function onModalClose(): void {
     props.setIsImportModalOpen(false);
     setFileContents(undefined);
@@ -142,6 +161,18 @@ export function ImportWorkflowModal(props: ImportWorkflowModalProps) {
               <EuiSpacer size="m" />
             </>
           )}
+          {isValidWorkflow(fileObj) && !isCompatible && inCompatibleDataSourceVersion && (
+            <>
+              <EuiFlexItem>
+                <EuiCallOut
+                  title={`The uploaded file is not compatible with the current data source version ${inCompatibleDataSourceVersion}. Upload a compatible file or switch to another data source.`}
+                  iconType={'alert'}
+                  color="danger"
+                />
+              </EuiFlexItem>
+              <EuiSpacer size="m" />
+            </>
+          )}
           {isValidWorkflow(fileObj) && !isValidUiWorkflow(fileObj) && (
             <>
               <EuiFlexItem>
@@ -230,6 +261,7 @@ export function ImportWorkflowModal(props: ImportWorkflowModalProps) {
         <EuiSmallButton
           disabled={
             !isValidWorkflow(fileObj) ||
+            !isCompatible ||
             isImporting ||
             isInvalidName(workflowName) ||
             isInvalidDescription(workflowDescription)

public/route_service.ts

@@ -334,7 +334,6 @@ export function configureRoutes(core: CoreStart): RouteService {
         return e as HttpFetchError;
       }
     },
-
     getIndex: async (index: string, dataSourceId?: string) => {
       try {
         const url = dataSourceId

public/utils/utils.tsx

@@ -157,6 +157,30 @@ export function isValidWorkflow(workflowObj: any): boolean {
   return workflowObj?.name !== undefined;
 }
 
+export async function isCompatibleWorkflow(
+  workflowObj: any, 
+  dataSourceId?: string | undefined
+): Promise<[boolean, string | undefined]> {
+  const compatibility = workflowObj?.version?.compatibility;
+
+  // Default to true when compatibility cannot be assessed (empty/invalid compatibility array or MDS disabled.)
+  if (!Array.isArray(compatibility) || compatibility.length === 0 || dataSourceId === undefined) {
+    return [true, undefined];
+  }
+
+  const dataSourceVersion = await getEffectiveVersion(dataSourceId);  
+  const [effectiveMajorVersion, effectiveMinorVersion] = dataSourceVersion.split('.').map(Number);
+
+  // Checks if any version in compatibility array matches the current dataSourceVersion (major.minor)
+  const isCompatible = compatibility.some(compatibleVersion => {
+    const [compatibleMajor, compatibleMinor] = compatibleVersion.split('.').map(Number);
+    return effectiveMajorVersion === compatibleMajor && effectiveMinorVersion === compatibleMinor;
+  });
+
+  return [isCompatible, `${effectiveMajorVersion}.${effectiveMinorVersion}`];
+}
+
+
 export function isValidUiWorkflow(workflowObj: any): boolean {
   return (
     isValidWorkflow(workflowObj) &&
@@ -530,7 +554,7 @@ export const getDataSourceId = () => {
 
 export const isDataSourceReady = (dataSourceId?: string) => {
   const dataSourceEnabled = getDataSourceEnabled().enabled;
-  return !dataSourceEnabled || (dataSourceId && dataSourceId !== '');
+  return !dataSourceEnabled || dataSourceId !== undefined;
 };
 
 // converts camelCase to a space-delimited string with the first word capitalized.