(sql: str)
| 63 | mz.set_environmentd_failpoints(failpoint) |
| 64 | |
| 65 | def sql_expect_crash(sql: str) -> None: |
| 66 | # We expect executing `sql` will crash environmentd. To ensure it is actually `sql` |
| 67 | # wait until the SQL interface is available. |
| 68 | mz.wait_for_sql() |
| 69 | try: |
| 70 | mz.environmentd.sql(sql) |
| 71 | except InterfaceError as e: |
| 72 | LOGGER.error(f"Expected SQL error: {e}") |
| 73 | |
| 74 | mz.environmentd.sql( |
| 75 | "CREATE CLUSTER shutdown1 REPLICAS (shutdown_replica1 (SIZE 'scale=1,workers=1'), shutdown_replica2 (SIZE 'scale=1,workers=1'))" |
no test coverage detected