fix

Author: huan233usc

.github/workflows/spark_v2_connector_test.yaml

@@ -105,20 +105,27 @@ jobs:
                   print(f"Warning: failed to parse {xml_file}: {e}")
 
           passed = totals["tests"] - totals["failures"] - totals["errors"] - totals["skipped"]
+          failed_count = totals["failures"] + totals["errors"]
 
           # Write failed tests to a file for the comment step
           with open("failed-tests-shard-${{ matrix.shard }}.json", "w") as f:
               json.dump(failed_tests, f)
 
-          print(f"Tests: {totals['tests']}, Passed: {passed}, "
-                f"Failed: {totals['failures'] + totals['errors']}, Skipped: {totals['skipped']}")
+          # Write summary for comment (passed / failed counts)
+          summary = {"tests": totals["tests"], "passed": passed, "failed": failed_count, "skipped": totals["skipped"]}
+          with open("summary-shard-${{ matrix.shard }}.json", "w") as f:
+              json.dump(summary, f)
+
+          print(f"Tests: {totals['tests']}, Passed: {passed}, Failed: {failed_count}, Skipped: {totals['skipped']}")
           PYEOF
       - name: Upload test results
         if: always() && steps.git-diff.outputs.diff
         uses: actions/upload-artifact@v4
         with:
           name: v2-test-results-shard-${{ matrix.shard }}
-          path: failed-tests-shard-${{ matrix.shard }}.json
+          path: |
+            failed-tests-shard-${{ matrix.shard }}.json
+            summary-shard-${{ matrix.shard }}.json
 
   comment:
     name: "V2 Connector: Post Results"
@@ -140,14 +147,29 @@ jobs:
               with open(f) as fh:
                   all_failed.extend(json.load(fh))
 
-          total_failed = len(all_failed)
+          total_tests = total_passed = total_failed = total_skipped = 0
+          for f in sorted(glob.glob("summary-shard-*.json")):
+              with open(f) as fh:
+                  s = json.load(fh)
+                  total_tests += s.get("tests", 0)
+                  total_passed += s.get("passed", 0)
+                  total_failed += s.get("failed", 0)
+                  total_skipped += s.get("skipped", 0)
+
+          total_failed_count = len(all_failed)  # from failed list (in case summary missing)
+          if total_tests == 0 and total_failed_count > 0:
+              total_failed = total_failed_count
+              total_passed = 0
+
           icon = "✅" if total_failed == 0 else "⚠️"
 
           lines = []
           lines.append(f"## {icon} Delta Spark V2 Connector Test Results")
           lines.append("")
           lines.append(f"**Mode:** `DELTA_V2_ENABLE_MODE=STRICT`")
           lines.append("")
+          lines.append(f"**{total_passed} passed**, {total_failed} failed, {total_skipped} skipped")
+          lines.append("")
           if total_failed == 0:
               lines.append("All tests passed! 🎉")
           else: