[ci] Enhancement: Integration Tests in Windows

Author: ppenna

tools/ci/job/factory.py

@@ -59,7 +59,7 @@ def unit_test(self, test_name: str) -> BaseJob:
 
     def integration_test(self, run_mode="") -> BaseJob:
         if self.config["platform"] == "windows":
-            raise Exception("Integration tests are not supported on Windows")
+            return windows.TcpIntegrationTestJobOnWindows(self.config)
         else:
             if self.config["libos"] == "catmem":
                 return linux.PipeIntegrationTestJobOnLinux(self.config, run_mode=run_mode)

tools/ci/job/windows.py

@@ -1,6 +1,8 @@
 # Copyright (c) Microsoft Corporation.
 # Licensed under the MIT license.
 
+import subprocess
+import time
 from ci.task.windows import BaseWindowsTask, CheckoutOnWindows, CompileOnWindows, RunOnWindows, CleanupOnWindows
 from ci.job.utils import wait_and_report
 from ci.job.generic import BaseJob
@@ -94,3 +96,25 @@ def __init__(self, config: dict):
 
     def execute(self) -> bool:
         return super().execute()
+
+
+class IntegrationTestJobOnWindows(BaseWindowsJob):
+    def __init__(self, config: dict, name: str):
+        super().__init__(config, name)
+
+    def execute(self, server_cmd: str) -> bool:
+        serverTask: RunOnWindows = RunOnWindows(
+            super().server(), super().repository(), server_cmd, super().is_debug(), super().is_sudo(), super().config_path())
+        return super().execute(serverTask)
+
+
+class TcpIntegrationTestJobOnWindows(IntegrationTestJobOnWindows):
+
+    def __init__(self, config: dict):
+        config["all_pass"] = True
+        super().__init__(config, "integration-test")
+        self.server_args: str = f"--local-address {super().server_addr()}:12345 --remote-address {super().client_addr()}:23456"
+
+    def execute(self) -> bool:
+        server_cmd: str = f"test-integration-rust TEST_INTEGRATION=tcp-test LIBOS={super().libos()} ARGS=\'{self.server_args}\'"
+        return super().execute(server_cmd)

tools/demikernel_ci.py

@@ -71,7 +71,7 @@ def run_pipeline(
     # STEP 4: Run integration tests.
     if test_integration:
         if status["checkout"] and status["compile"]:
-            if libos == "catnap" or libos == "catloop":
+            if libos == "catnap" or libos == "catnapw" or libos == "catloop":
                 status["integration_tests"] = factory.integration_test().execute()
             elif libos == "catmem":
                 status["integration_tests"] = factory.integration_test("standalone").execute()