From 371d568c9d82a34552b15c68611bd3a4ee11f1d6 Mon Sep 17 00:00:00 2001 From: Yusuf Ali Date: Mon, 31 Mar 2025 00:30:51 -0400 Subject: [PATCH] fix(lake): declare tenant tables for lake house --- servc/svc/com/storage/delta.py | 5 +++++ servc/svc/com/storage/iceberg.py | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/servc/svc/com/storage/delta.py b/servc/svc/com/storage/delta.py index 9f606d5..b550ac0 100644 --- a/servc/svc/com/storage/delta.py +++ b/servc/svc/com/storage/delta.py @@ -6,6 +6,7 @@ from pyarrow import Schema, Table from servc.svc.com.storage.lake import Lake, LakeTable +from servc.svc.com.storage.tenant import TenantTable from servc.svc.config import Config @@ -186,3 +187,7 @@ def _close(self): self._isOpen = False return True return False + + +class DeltaTenant(TenantTable, Delta): + pass diff --git a/servc/svc/com/storage/iceberg.py b/servc/svc/com/storage/iceberg.py index c8e53da..e12459d 100644 --- a/servc/svc/com/storage/iceberg.py +++ b/servc/svc/com/storage/iceberg.py @@ -12,6 +12,7 @@ from pyiceberg.types import NestedField from servc.svc.com.storage.lake import Lake, LakeTable +from servc.svc.com.storage.tenant import TenantTable from servc.svc.config import Config @@ -198,3 +199,7 @@ def read( ) -> paTable: data = self.readRaw(columns, partitions, version, options) return data.to_arrow() + + +class IceBergTenant(TenantTable, IceBerg): + pass