formatting

Author: cmoyes-jump

src/test_suite/fuzzcorp_api_client.py

@@ -43,7 +43,7 @@ def from_dict(cls, data: Dict[str, Any]) -> "LineageRepro":
         if not hash_value:
             raise KeyError("Hash")
 
-        # CreatedAt is present in both schemas; normalise if available
+        # CreatedAt is present in both schemas, normalize if available
         created_at_str = data.get("CreatedAt") or data.get("created_at")
         if created_at_str:
             # Handle both RFC3339 formats
@@ -55,22 +55,22 @@ def from_dict(cls, data: Dict[str, Any]) -> "LineageRepro":
             created_at = datetime.min
 
         # Count:
-        #   - prefer explicit Count from legacy schema
-        #   - otherwise derive from ConfigIndices (one count per config index)
-        #   - final fallback is a single repro
+        # - prefer explicit Count from legacy schema
+        # - otherwise derive from ConfigIndices (one count per config index)
+        # - final fallback is a single repro
         if "Count" in data:
             count = int(data["Count"])
         else:
             cfg_indices = data.get("ConfigIndices") or data.get("config_indices") or []
             if isinstance(cfg_indices, list):
                 count = max(len(cfg_indices), 1) if cfg_indices else 1
             else:
-                # Unexpected shape; treat as a single repro
+                # Unexpected shape: treat as a single repro
                 count = 1
 
         # AllVerified:
-        #   - legacy AllVerified flag if present
-        #   - otherwise fall back to the newer Verified flag
+        # - legacy AllVerified flag if present
+        # - otherwise fall back to the newer Verified flag
         if "AllVerified" in data:
             all_verified = bool(data["AllVerified"])
         else:
@@ -103,8 +103,8 @@ def from_dict(cls, data: Dict[str, Any]) -> "ReproIndexResponse":
             lineages[lineage_name] = [LineageRepro.from_dict(r) for r in (repros or [])]
 
         # Bundle ID:
-        #   - legacy compat: top-level "BundleID"
-        #   - current NG API: "Bundle" object with "id" field
+        # - legacy compat: top-level "BundleID"
+        # - current NG API: "Bundle" object with "id" field
         bundle_id = data.get("BundleID")
         if not bundle_id:
             bundle = data.get("Bundle") or data.get("bundle")

src/test_suite/multiprocessing_utils.py

@@ -684,17 +684,17 @@ def download_and_process(source):
                     project=config.get_project(),
                 )
 
-        # Require at least one artifact hash; if none are present, there is
-        # nothing we can download or convert into fixtures.
+        # Require at least one artifact hash. If none are present, there is
+        # nothing we can download or convert into fixtures...
         if not repro_metadata.artifact_hashes:
             return {
                 "success": False,
                 "repro": f"{section_name}/{crash_hash}",
                 "message": "Failed to process: no artifacts found",
             }
 
-        # Determine which artifacts to download: always process all available
-        # artifacts for this repro. Any duplicates will be naturally deduplicated
+        # Determine which artifacts to download: Always process all available
+        # artifacts for this repro. Any duplicates will be naturally deduped
         # later at the fixture level by hash.
         artifacts_to_download = repro_metadata.artifact_hashes
         print(

src/test_suite/test_suite.py

@@ -683,7 +683,7 @@ def decode_protobufs(
             use_processes=True,
         )
     except BrokenProcessPool:
-        # Worker crash already described; exit without a verbose traceback.
+        # Worker crash already described: exit without a verbose traceback.
         raise typer.Exit(code=1)
 
     print("-" * LOG_FILE_SEPARATOR_LENGTH)
@@ -946,7 +946,7 @@ def download_fixture(
             print(f"[ERROR] Response: {e.response.text}")
         raise typer.Exit(code=1)
     except typer.Exit:
-        # Allow clean exits (e.g., from process_items) without extra tracebacks.
+        # Allow clean exits (e.g. from process_items) without extra tracebacks.
         raise
     except Exception as e:
         print(f"[ERROR] Failed to download fixtures: {e}")