Adding tests and log statements

Author: muralibasani

release/github.py

@@ -17,22 +17,37 @@
 
 """
 Auxiliary functions to interact with the GitHub REST API.
+
+Set the GITHUB_REPO environment variable to override the target repository
+(e.g. "myuser/kafka" to test against a personal fork).
+
+Set GITHUB_DRY_RUN=true to print API calls without executing them.
 """
 
 import json
+import os
 import urllib.request
 
 from runtime import fail
 
 GITHUB_API_URL = "https://api.github.com"
-GITHUB_REPO = "apache/kafka"
+GITHUB_REPO = os.environ.get("GITHUB_REPO", "apache/kafka")
+DRY_RUN = os.environ.get("GITHUB_DRY_RUN", "").lower() in ("true", "1", "yes")
 
 
 def _api_request(token, method, path, body=None):
     """
     Make an authenticated request to the GitHub REST API.
+    In dry-run mode, prints the request details without executing.
     """
     url = f"{GITHUB_API_URL}{path}"
+
+    if DRY_RUN:
+        print(f"[DRY RUN] {method} {url}")
+        if body:
+            print(f"[DRY RUN] Body: {json.dumps(body, indent=2)}")
+        return None
+
     data = json.dumps(body).encode("utf-8") if body else None
     req = urllib.request.Request(url, data=data, method=method)
     req.add_header("Accept", "application/vnd.github.v3+json")
@@ -56,7 +71,7 @@ def trigger_workflow(token, workflow_file, ref, inputs):
     """
     path = f"/repos/{GITHUB_REPO}/actions/workflows/{workflow_file}/dispatches"
     body = {"ref": ref, "inputs": inputs}
-    print(f"Triggering workflow {workflow_file} with inputs: {json.dumps(inputs)}")
+    print(f"Triggering workflow {workflow_file} on {GITHUB_REPO} with inputs: {json.dumps(inputs)}")
     _api_request(token, "POST", path, body)
     print(f"Successfully triggered {workflow_file}")
 
@@ -65,6 +80,10 @@ def trigger_docker_build_test(token, ref, image_type, kafka_url):
     """
     Trigger the Docker Build Test workflow for the given image type.
     """
+    print(f"\n--- Docker Build Test ({image_type}) ---")
+    print(f"  Image type : {image_type}")
+    print(f"  Branch/ref : {ref}")
+    print(f"  Kafka URL  : {kafka_url}")
     trigger_workflow(token, "docker_build_and_test.yml", ref, {
         "image_type": image_type,
         "kafka_url": kafka_url,
@@ -75,6 +94,11 @@ def trigger_docker_rc_release(token, ref, image_type, rc_docker_image, kafka_url
     """
     Trigger the Docker RC Release workflow for the given image type.
     """
+    print(f"\n--- Docker RC Release ({image_type}) ---")
+    print(f"  Image type   : {image_type}")
+    print(f"  Docker image : {rc_docker_image}")
+    print(f"  Branch/ref   : {ref}")
+    print(f"  Kafka URL    : {kafka_url}")
     trigger_workflow(token, "docker_rc_release.yml", ref, {
         "image_type": image_type,
         "rc_docker_image": rc_docker_image,

release/release.py

@@ -374,17 +374,28 @@ def delete_gitrefs():
 git.push_ref(starting_branch)
 
 # Trigger Docker image build and test workflows via GitHub Actions
+print("\n=== Docker Image Workflows ===")
+if github.DRY_RUN:
+    print("NOTE: GITHUB_DRY_RUN is enabled. No actual API calls will be made.")
+if github.GITHUB_REPO != "apache/kafka":
+    print(f"NOTE: Using custom repository: {github.GITHUB_REPO}")
 if confirm("Trigger Docker image build workflows via GitHub Actions?"):
     github_token = preferences.get('github_token', lambda: prompt("Enter your GitHub personal access token (with 'actions' scope): "))
     kafka_url = f"https://dist.apache.org/repos/dist/dev/kafka/{rc_tag}/kafka_2.13-{release_version}.tgz"
+    print(f"\nStep 1/2: Triggering Docker Build Test workflows for JVM and native images...")
     for image_type in ["jvm", "native"]:
         github.trigger_docker_build_test(github_token, dev_branch, image_type, kafka_url)
+    print("\nDocker Build Test workflows triggered successfully for both JVM and native images.")
     if confirm("Also trigger Docker RC release workflows to push RC images to DockerHub?"):
+        print(f"\nStep 2/2: Triggering Docker RC Release workflows for JVM and native images...")
         for image_type in ["jvm", "native"]:
             docker_image_name = "apache/kafka-native" if image_type == "native" else "apache/kafka"
             rc_docker_image = f"{docker_image_name}:{rc_tag}"
             github.trigger_docker_rc_release(github_token, dev_branch, image_type, rc_docker_image, kafka_url)
-    print(f"\nDocker workflow runs can be monitored at: https://github.com/apache/kafka/actions")
+        print("\nDocker RC Release workflows triggered successfully for both JVM and native images.")
+    print(f"\nAll Docker workflow runs can be monitored at: https://github.com/{github.GITHUB_REPO}/actions")
+else:
+    print("Skipping Docker image workflows.")
 
 # Move back to starting branch and clean out the temporary release branch (e.g. 1.0.0) we used to generate everything
 git.reset_hard_head()