TMP Python

Author: kaikulimu

src/integration-tests/test_restart.py

@@ -46,9 +46,10 @@ def configure_cluster(cluster: Cluster, is_fsm: bool):
             cluster_attr = my_clusters[0].cluster_attributes
             cluster_attr.is_cslmode_enabled = is_fsm
             cluster_attr.is_fsmworkflow = is_fsm
-            cluster_attr.doesFSMwriteQLIST = True
+            cluster_attr.does_fsmwrite_qlist = True
     cluster.deploy_domains()
 
+
 def ensureMessageAtStorageLayer(cluster: Cluster, partitionId: int, queueUri: str, numMessages: int):
     '''
     Assert that in the `partitionId` of the `cluster`, there are exactly
@@ -154,6 +155,7 @@ def wait_replication():
 
 @tweak.cluster.cluster_attributes.is_cslmode_enabled(False)
 @tweak.cluster.cluster_attributes.is_fsmworkflow(False)
+@tweak.cluster.cluster_attributes.does_fsmwrite_qlist(True)
 def test_restart_between_non_FSM_and_FSM(cluster: Cluster, domain_urls: tc.DomainUrls):
     """
     This test verifies that we can safely switch clusters between non-FSM and

src/python/blazingmq/dev/configurator/__init__.py

@@ -318,7 +318,7 @@ def _cluster_definition_partial_prototype(partition_config: mqbcfg.PartitionConf
             ack_window_size=500,
         ),
         cluster_attributes=mqbcfg.ClusterAttributes(
-            is_cslmode_enabled=True, is_fsmworkflow=True
+            is_cslmode_enabled=True, is_fsmworkflow=True, does_fsmwrite_qlist = True
         ),
         cluster_monitor_config=mqbcfg.ClusterMonitorConfig(
             max_time_leader=15,

src/python/blazingmq/dev/it/fixtures.py

@@ -481,6 +481,7 @@ def tweak(self, cluster: mqbcfg.ClusterDefinition):
         # 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
+        cluster.cluster_attributes.does_fsmwrite_qlist = True
 
     @property
     def suffix(self) -> str: