GeezerVison is showing github.com — feldera/python/felderize/felderize/models.py at main · feldera/feldera

Expand file tree

models.py

Copy path

More file actions

33 lines (26 loc) · 960 Bytes

Copy path

33 lines (26 loc) · 960 Bytes

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

from __future__ import annotations

from dataclasses import dataclass, field

from enum import Enum

class Status(str, Enum):

SUCCESS = "success"

UNSUPPORTED = "unsupported"

ERROR = "error"

@dataclass

class TranslationResult:

"""Result of a Spark SQL → Feldera SQL translation attempt."""

feldera_schema: str = ""

feldera_query: str = ""

unsupported: list[str] = field(default_factory=list)

warnings: list[str] = field(default_factory=list)

explanations: list[str] = field(default_factory=list)

status: Status = Status.SUCCESS

def to_dict(self) -> dict:

"""Serialize to a JSON-compatible dictionary."""

return {

"feldera_schema": self.feldera_schema,

"feldera_query": self.feldera_query,

"unsupported": self.unsupported,

"warnings": self.warnings,

"explanations": self.explanations,

"status": self.status.value,

}