...

Author: pedrohrfz

runtime-create-manifest-action/script.py

@@ -6,39 +6,50 @@
 # Configure logging
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
 
-def check(result: subprocess.CompletedProcess) -> None:
+
+def check(result: subprocess.Popen) -> None:
     """
     Checks the result of a subprocess execution. If the return code is non-zero, 
     it logs an error message and exits the program.
 
     Args:
-        result (subprocess.CompletedProcess): The result of the subprocess execution.
+        result (subprocess.Popen): The result of the subprocess execution.
     """
+    result.wait()  # Wait for the process to complete
     if result.returncode != 0:
         logging.error(f"Failed to execute: {result.args}")
-        logging.error(f"Error output: {result.stderr}")
+        logging.error(f"Error output: {result.stderr.read()}")
         sys.exit(1)
 
-def run_command(command: List[str]) -> subprocess.CompletedProcess:
+
+def run_command(command: List[str]) -> subprocess.Popen:
     """
-    Runs a command using subprocess and returns the result.
+    Runs a command using subprocess.Popen and returns the result.
 
     Args:
         command (List[str]): The command to be executed as a list of strings.
 
     Returns:
-        subprocess.CompletedProcess: The result of the command execution.
+        subprocess.Popen: The result of the command execution.
     """
     try:
         logging.info(f"Running command: {' '.join(command)}")
-        result = subprocess.run(command, capture_output=True, text=True)
-        check(result)
-        return result
+        # Start the process
+        process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        
+        # Read and print output in real-time
+        for line in process.stdout:
+            print(line, end="")  # Print each line as it is produced
+        
+        # Check the result after the process completes
+        check(process)
+        return process
     except Exception as e:
         logging.error(f"Exception occurred while running command: {command}")
         logging.error(str(e))
         sys.exit(1)
 
+    
 def run(metadata) -> None:
     """
     Executes a series of StackSpot CLI commands to set the workspace and deploy a plan.

runtime-deploy-action/script.py

@@ -2,6 +2,7 @@
 import sys
 import subprocess
 import logging
+from typing import List
 
 # Configure logging
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
@@ -84,7 +85,7 @@ def run(metadata):
     cmd = [
         "docker", 
         "run", "--rm",
-        "--entrypoint=/app/stackspot-runtime-job-deploy"
+        "--entrypoint=/app/stackspot-runtime-job-deploy",
         container_url,
         "start", 
         f"--run-task-id={run_task_id}", 

runtime-iac-action/script.py

@@ -2,6 +2,7 @@
 import sys
 import subprocess
 import logging
+from typing import List
 
 # Configure logging
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
@@ -11,75 +12,88 @@
 STK_RUNTIME_MANAGER_DOMAIN = os.getenv("STK_RUNTIME_MANAGER_DOMAIN", "https://runtime-manager.v1.stackspot.com")
 
 
-def check(result: subprocess.CompletedProcess) -> None:
+def check(result: subprocess.Popen) -> None:
     """
     Checks the result of a subprocess execution. If the return code is non-zero, 
     it logs an error message and exits the program.
 
     Args:
-        result (subprocess.CompletedProcess): The result of the subprocess execution.
+        result (subprocess.Popen): The result of the subprocess execution.
     """
+    result.wait()  # Wait for the process to complete
     if result.returncode != 0:
         logging.error(f"Failed to execute: {result.args}")
-        logging.error(f"Error output: {result.stderr}")
+        logging.error(f"Error output: {result.stderr.read()}")
         sys.exit(1)
 
-def run_command(command: List[str]) -> subprocess.CompletedProcess:
+
+def run_command(command: List[str]) -> subprocess.Popen:
     """
-    Runs a command using subprocess and returns the result.
+    Runs a command using subprocess.Popen and returns the result.
 
     Args:
         command (List[str]): The command to be executed as a list of strings.
 
     Returns:
-        subprocess.CompletedProcess: The result of the command execution.
+        subprocess.Popen: The result of the command execution.
     """
     try:
         logging.info(f"Running command: {' '.join(command)}")
-        result = subprocess.run(command, capture_output=True, text=True)
-        check(result)
-        return result
+        # Start the process
+        process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        
+        # Read and print output in real-time
+        for line in process.stdout:
+            print(line, end="")  # Print each line as it is produced
+        
+        # Check the result after the process completes
+        check(process)
+        return process
     except Exception as e:
         logging.error(f"Exception occurred while running command: {command}")
         logging.error(str(e))
         sys.exit(1)
 
 
-
-def run(metadata):
-    inputs: dict = metadata.inputs
-    container_url: str = 'stackspot/runtime-job-iac:latest'
-    run_task_id: str = inputs["run_task_id"]
-    base_path_output: str = inputs.get("base_path_output") or "."
-    path_to_mount: str = inputs.get("path_to_mount") or "."
-    path_to_mount = f"{path_to_mount}:/app-volume" 
-
+def build_flags(inputs: dict) -> list:
     docker_flags: dict = dict(
         FEATURES_LEVEL_LOG=inputs.get("features_level_log") or "info",
 
+        REPOSITORY_NAME=inputs["repository_name"],
         AUTHENTICATE_CLIENT_ID=inputs["client_id"],
         AUTHENTICATE_CLIENT_SECRET=inputs["client_key"],
         AUTHENTICATE_CLIENT_REALMS=inputs["client_realm"],
-        REPOSITORY_NAME=inputs["repository_name"],
+        AWS_ACCESS_KEY_ID=inputs['aws_access_key_id'],
+        AWS_SECRET_ACCESS_KEY=inputs['aws_secret_access_key'],
+        AWS_SESSION_TOKEN=inputs['aws_session_token'],
         AWS_REGION=inputs["aws_region"],
 
         AUTHENTICATE_URL=STK_IAM_DOMAIN,
         FEATURES_API_MANAGER=STK_RUNTIME_MANAGER_DOMAIN,
     )
+    flags = []
+    for k, v in docker_flags.items():
+        flags += ["-e", f"{k}={v}"]
+    
+    return flags
+
+
+def run(metadata):
+    inputs: dict = metadata.inputs
+    container_url: str = 'stackspot/runtime-job-iac:latest'
+    run_task_id: str = inputs["run_task_id"]
+    base_path_output: str = inputs.get("base_path_output") or "."
+    path_to_mount: str = inputs.get("path_to_mount") or "."
+    path_to_mount = f"{path_to_mount}:/app-volume" 
 
-    cmd = [
-        "docker", 
-        "run", "--rm",
+    flags = build_flags(inputs)
+    cmd = ["docker", "run", "--rm", "-v", path_to_mount] + flags + [
         "--entrypoint=/app/stackspot-runtime-job-iac",
         container_url, 
         "start",
         f"--run-task-id={run_task_id}", 
         f"--base-path-output={base_path_output}", 
-        "-v", path_to_mount
     ]
-    flags = []
-    for k, v in docker_flags.items():
-        flags += ["-e", f"{k}={v}"]
-    docker_run = cmd + flags
+    docker_run = cmd
 
     run_command(docker_run)

runtime-run-all/script.py

@@ -33,5 +33,5 @@ def run(metadata):
         DEPLOY_SELF_HOSTED=lambda **i: run_action("runtime-deploy-action", **i),
     )
     for t in data['tasks']:
-        runner = task_runners.get(t["taskType"]) 
-        runner(run_task_id=t["runTaskId"])
+        runner = task_runners.get(t["taskType"])
+        runner and runner(run_task_id=t["runTaskId"])