Release 0.6.1: fix special-symbol workload transaction boundaries

Author: O2eg

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "pg-workload"
-version = "0.6.0"
+version = "0.6.1"
 description = "PostgreSQL workload emulator for diagnostic and observability testing"
 readme = "README.md"
 requires-python = ">=3.10"

src/pg_workload/__init__.py

@@ -1,6 +1,6 @@
 """PostgreSQL workload generation and scheduling tools."""
 
-__version__ = "0.6.0"
+__version__ = "0.6.1"
 
 from pg_workload.assets import bundled_profiles_root, initialize_project
 from pg_workload.cli import build_parser

src/pg_workload/bundled/profiles/simple_stock_spec_symbols/sql/01_workload.sql

@@ -35,7 +35,7 @@ SELECT
         WHEN random() < 0.3 THEN '-Infinity'::double precision -- -Infinity
         ELSE random() * 1e18 -- Very large floating-point value
     END AS "Fließkomma\r\nCRLF$#@&", -- Fließkomma$#@& (double precision)
-    'descr ' || generate_series(1,50) || ' <script>alert("XSS!");</script> <!-- SQL --> OR 1=1; DROP TABLE "Stock_$#@.&\n\r_items"; --' -- "ThisIsAVeryLongFieldNameThatWillBreakTheLayoutIfNotHandledPrope";
+    'descr ' || generate_series(1,50) || ' <script>alert("XSS!");</script> <!-- SQL --> OR 1=1; DROP TABLE "Stock_$#@.&\n\r_items"; --'; -- "ThisIsAVeryLongFieldNameThatWillBreakTheLayoutIfNotHandledPrope"
 COMMIT;
 
 BEGIN;

tests/test_docker_postgres18.py

@@ -647,6 +647,14 @@ def test_postgres18_container_runs_all_smoke_profiles(self):
         )
 
         for profile_name in profile_names:
+            if profile_name == "simple_stock_spec_symbols":
+                profile = profiles[profile_name]
+                for job in profile.jobs:
+                    self.assertNotIn(
+                        "there is already a transaction in progress",
+                        profile.log_path(job).read_text(encoding="utf-8"),
+                        "Each stock operation must commit before the next BEGIN",
+                    )
             invariant_sql = PROFILE_INVARIANTS.get(profile_name)
             if invariant_sql is None:
                 self.fail(f"No post-run invariant defined for bundled profile {profile_name}")