platform-checks & parallel-workload. Allow multi-replica clusters with webhook sources

Author: def-

misc/python/materialize/checks/all_checks/webhook.py

@@ -25,7 +25,8 @@ def initialize(self) -> Testdrive:
             schemas()
             + dedent(
                 """
-                > CREATE CLUSTER webhook_cluster REPLICAS (r1 (SIZE '1'));
+                >[version>=14700] CREATE CLUSTER webhook_cluster REPLICATION FACTOR 2
+                >[version<14700] CREATE CLUSTER webhook_cluster REPLICATION FACTOR 1
 
                 > CREATE SOURCE webhook_text IN CLUSTER webhook_cluster FROM WEBHOOK BODY FORMAT TEXT;
 
@@ -144,7 +145,7 @@ def initialize(self) -> Testdrive:
             schemas()
             + dedent(
                 """
-                > CREATE CLUSTER webhook_table_cluster REPLICAS (r1 (SIZE '1'));
+                > CREATE CLUSTER webhook_table_cluster REPLICATION FACTOR 2
                 > SET cluster = webhook_table_cluster
                 > CREATE TABLE webhook_table_text FROM WEBHOOK BODY FORMAT TEXT;
                 > SET cluster = quickstart

misc/python/materialize/parallel_workload/action.py

@@ -1956,14 +1956,6 @@ def run(self, exe: Executor) -> bool:
 
 
 class CreateWebhookSourceAction(Action):
-    def errors_to_ignore(self, exe: Executor) -> list[str]:
-        result = super().errors_to_ignore(exe)
-        if exe.db.scenario in (Scenario.Kill, Scenario.ZeroDowntimeDeploy):
-            result.extend(
-                ["cannot create webhook source in cluster with more than one replica"]
-            )
-        return result
-
     def run(self, exe: Executor) -> bool:
         with exe.db.lock:
             if len(exe.db.webhook_sources) >= MAX_WEBHOOK_SOURCES:
@@ -1975,7 +1967,7 @@ def run(self, exe: Executor) -> bool:
         with schema.lock, cluster.lock:
             if schema not in exe.db.schemas:
                 return False
-            if cluster not in exe.db.clusters or len(cluster.replicas) != 1:
+            if cluster not in exe.db.clusters:
                 return False
 
             source = WebhookSource(webhook_source_id, cluster, schema, self.rng)