feat: support custom product versions

Author: dervoeti

tests/templates/kuttl/smoke/check-s3.py

@@ -2,6 +2,7 @@
 import trino
 import argparse
 import sys
+import re
 
 if not sys.warnoptions:
     import warnings
@@ -48,8 +49,11 @@ def run_query(connection, query):
     trino_version = run_query(connection, "select node_version from system.runtime.nodes where coordinator = true and state = 'active'")[0][0]
     print(f"[INFO] Testing against Trino version \"{trino_version}\"")
 
-    assert len(trino_version) >= 3
-    assert trino_version.isnumeric()
+    # Strip SDP release suffix from the version string
+    trino_product_version = re.split(r'-stackable', trino_version, maxsplit=1)[0]
+
+    assert len(trino_product_version) >= 3
+    assert trino_product_version.isnumeric()
     assert trino_version == run_query(connection, "select version()")[0][0]
 
     run_query(connection, "CREATE SCHEMA IF NOT EXISTS hive.minio WITH (location = 's3a://trino/')")

tests/templates/kuttl/smoke_aws/check-s3.py

@@ -2,6 +2,7 @@
 import trino
 import argparse
 import sys
+import re
 
 if not sys.warnoptions:
     import warnings
@@ -57,8 +58,11 @@ def run_query(connection, query):
     )[0][0]
     print(f'[INFO] Testing against Trino version "{trino_version}"')
 
-    assert len(trino_version) >= 3
-    assert trino_version.isnumeric()
+    # Strip SDP release suffix from the version string
+    trino_product_version = re.split(r'-stackable', trino_version, maxsplit=1)[0]
+
+    assert len(trino_product_version) >= 3
+    assert trino_product_version.isnumeric()
     assert trino_version == run_query(connection, "select version()")[0][0]
 
     # WARNING (@NickLarsenNZ): Hard-coded bucket