Fix[IT]: CSL+FSM together or both disabled; rollback new python features (#592)

Signed-off-by: Evgeny Malygin <[email protected]>

Author: 678098

Diff for: src/integration-tests/pytest.ini

@@ -14,6 +14,5 @@ markers =
     single
     multi
     legacy_mode
-    csl_mode
     fsm_mode
     flakey

Diff for: src/integration-tests/run-tests

@@ -11,7 +11,7 @@
 # =====
 #   ./run-tests
 #   ./run-tests "legacy_mode"
-#   ./run-tests "not csl_mode"
+#   ./run-tests "not fsm_mode"
 #   ./run-tests "legacy_mode or fsm_mode"
 #   export BLAZINGMQ_IT_PRESET="fsm_mode" && ./run-tests
 

Diff for: src/python/blazingmq/dev/it/README.md

@@ -370,9 +370,8 @@ Tests can be selected using keywords (using the `-k` switch) and/or markers
 | `pr_integrationtest`    | integration tests to be run as part of a Jenkins PR (currently all tests) |
 | `single`                | tests that use a local cluster fixture                                    |
 | `multi`                 | tests that use a 4-node, 2-proxy cluster fixture                          |
-| `legacy_mode`           | choice between: legacy, CSL, FSM                                          |
-| `csl_mode`              | choice between: legacy, CSL, FSM                                          |
-| `fsm_mode`              | choice between: legacy, CSL, FSM                                          |
+| `legacy_mode`           | choice between: legacy, FSM (with CSL)                                    |
+| `fsm_mode`              | choice between: legacy, FSM (with CSL)                                    |
 | `flakey`                | tests that occasionally fail; excluded from the Jenkins PR check          |
 
 ### Erroneous Exits

Diff for: src/python/blazingmq/dev/it/fixtures.py

@@ -453,22 +453,21 @@ def break_before_test(request, cluster):
 
 class Mode(IntEnum):
     LEGACY = 0
-    CSL = 1
-    FSM = 2
+    FSM = 1
 
     def tweak(self, cluster: mqbcfg.ClusterDefinition):
-        cluster.cluster_attributes.is_cslmode_enabled = self >= Mode.CSL
+        # CSL and FSM settings must be either both enabled or both disabled
+        cluster.cluster_attributes.is_cslmode_enabled = self == Mode.FSM
         cluster.cluster_attributes.is_fsmworkflow = self == Mode.FSM
 
     @property
     def suffix(self) -> str:
-        return ["", "_csl", "_fsm"][self]
+        return ["", "_fsm"][self]
 
     @property
     def marks(self):
         return [
             [pytest.mark.legacy_mode],
-            [pytest.mark.csl_mode],
             [pytest.mark.fsm_mode],
         ][self]
 

Diff for: src/python/blazingmq/dev/it/process/client.py

@@ -41,8 +41,8 @@
 
 
 class CommandResult(NamedTuple):
-    error_code: int | None
-    matches: List[re.Match | None] | None
+    error_code: Optional[int]
+    matches: Optional[List[Optional[re.Match]]]
 
 
 blocktimeout = 15
@@ -378,7 +378,7 @@ def list(self, uri=None, block=None) -> List[Message]:
 
     def confirm(
         self, uri, guid, block=None, succeed=None, no_except=None
-    ) -> int | None:
+    ) -> Optional[int]:
         command = _build_command(f'confirm uri="{uri}" guid="{guid}"', {}, {})
         with internal_use(self):
             res = self._command_helper(