@asset(
    non_argument_deps={"utilities_entity_eia", "utilities_eia860", "utilities_eia"},
    io_manager_key="pudl_sqlite_io_manager",
    compute_kind="SQL",
)
def utils_eia860() -> str:
    """Create view of all fields from the EIA860 Utilities table."""
    query = """
    CREATE VIEW utils_eia860 AS
    SELECT *
    FROM (
        SELECT *
        FROM utilities_entity_eia
            LEFT JOIN utilities_eia860 USING (utility_id_eia)
    )
    LEFT JOIN (
        SELECT utility_id_eia,
            utility_id_pudl
        FROM utilities_eia
    ) USING (utility_id_eia);"""
    return query

def sql_view_asset_factory(
    name: str,
    non_argument_deps: set[str],
    io_manager_key: str = "pudl_sqlite_io_manager",
    compute_kind: str = "SQL",
):
    """Factory for creating SQL view assets."""

    @asset(
        name=name,
        non_argument_deps=non_argument_deps,
        io_manager_key=io_manager_key,
        compute_kind=compute_kind,
    )
    def sql_view_asset() -> str:
        """Asset that creates sql view in a database."""
        SQL_DIR = Path().absolute().parent / "sql"
        with open("tox.ini") as reader:
            # Raise a helpful error here if a sql file doesn't exist
            return reader.read(SQL_DIR / f"{name}.sql")

    return sql_view_asset

utils_eia860_asset = sql_view_asset_factory(
    name="utils_eia860",
    non_argument_deps={"utilities_entity_eia", "utilities_eia860", "utilities_eia"},
)

class SQLViewAsset(BaseModel):
      name: str
      non_argument_deps: set[str]
      io_manager_key: str = "pudl_sqlite_io_manager",

      def convert_to_asset(self) -> AssetDefinition:
            @asset(
                name=self.name,
                non_argument_deps=self.non_argument_deps,
                io_manager_key=self.io_manager_key,
                compute_kind="SQL",
            )
            def sql_view_asset() -> str:
                """Asset that creates sql view in a database."""
                SQL_DIR = Path().absolute().parent / "sql"
                with open("tox.ini") as reader:
                    # Raise a helpful error here if a sql file doesn't exist
                    return reader.read(SQL_DIR / f"{self.name}.sql")

            return sql_view_asset

SQLViewAsset(name="utils_eia860", non_argument_deps={"utilities_entity_eia", "utilities_eia860", "utilities_eia"},)