Function td

test/cloud-canary/mzcompose.py:366–434

(
    c: Composition,
    filename: str | None = None,
    text: str | None = None,
    redpanda: Redpanda | None = None,
)

def td(
    c: Composition,
    filename: str | None = None,
    text: str | None = None,
    redpanda: Redpanda | None = None,
) -> None:
    assert APP_PASSWORD is not None
    materialize_url = f"postgres://{urllib.parse.quote(USERNAME)}:{urllib.parse.quote(APP_PASSWORD)}@{urllib.parse.quote(c.cloud_hostname())}:6875"

    assert bool(filename) != bool(text)

    testdrive = Testdrive(
        default_timeout="1200s",
        materialize_url=materialize_url,
        no_reset=True,  # Required so that admin port 6877 is not used
        seed=1,  # Required for predictable Kafka topic names
        kafka_url=KAFKA_BOOTSTRAP_SERVER,
        schema_registry_url=SCHEMA_REGISTRY_ENDPOINT,
        no_consistency_checks=True,
        environment=[
            "KAFKA_OPTION="
            + ",".join(
                [
                    "security.protocol=SASL_SSL",
                    "sasl.mechanisms=PLAIN",
                    f"sasl.username={CONFLUENT_API_KEY}",
                    f"sasl.password={CONFLUENT_API_SECRET}",
                ]
            ),
        ],
        entrypoint_extra=[
            f"--var=confluent-api-key={CONFLUENT_API_KEY}",
            f"--var=confluent-api-secret={CONFLUENT_API_SECRET}",
        ],
    )

    if redpanda and "redpanda" in str(filename):
        testdrive = Testdrive(
            default_timeout="1200s",
            materialize_url=materialize_url,
            no_reset=True,  # Required so that admin port 6877 is not used
            seed=1,  # Required for predictable Kafka topic names
            kafka_url=redpanda.cluster_info["kafka_api"]["seed_brokers"][0],
            schema_registry_url=redpanda.cluster_info["schema_registry"]["url"],
            no_consistency_checks=True,
            environment=[
                "KAFKA_OPTION="
                + ",".join(
                    [
                        "security.protocol=SASL_SSL",
                        "sasl.mechanisms=SCRAM-SHA-512",
                        f"sasl.username={REDPANDA_USER}",
                        f"sasl.password={redpanda.password}",
                    ]
                ),
            ],
            entrypoint_extra=[
                f"--var=redpanda-username={REDPANDA_USER}",