Function create_namespace

misc/python/materialize/biglake.py:169–186

Create the namespace. BigLake doesn't auto-create on first commit. With ``exist_ok`` (the default), a 409 from a namespace that already exists is treated as success, so this is safe to call repeatedly against a fixed long-lived namespace.

(
    token: str, project: str, prefix: str, namespace: str, *, exist_ok: bool = True
)

def create_namespace(
    token: str, project: str, prefix: str, namespace: str, *, exist_ok: bool = True
) -> None:
    """Create the namespace. BigLake doesn't auto-create on first commit.

    With ``exist_ok`` (the default), a 409 from a namespace that already exists
    is treated as success, so this is safe to call repeatedly against a fixed
    long-lived namespace.
    """
    req = biglake_request("POST", catalog_url(prefix, "namespaces"), token, project)
    req.add_header("Content-Type", "application/json")
    req.data = json.dumps({"namespace": [namespace]}).encode()
    try:
        urllib.request.urlopen(req)
    except urllib.error.HTTPError as e:
        if exist_ok and e.code == 409:
            return
        raise


def bootstrap_namespace(service_account: dict, bucket: str, namespace: str) -> str: