Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions be/app/insights/runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -170,17 +170,18 @@ def run_for_table(self, table_identifier, rule_ids: List[str] = None, type: str

return run_result

def run_for_namespace(self, namespace: str, rule_ids: List[str] = None, recursive: bool = True, type: str = "manual") -> Dict[str, List[Insight]]:
def run_for_namespace(self, namespace: str, rule_ids: List[str] = None, recursive: bool = False, type: str = "manual") -> Dict[str, List[Insight]]:
tables = self.lakeview.get_tables(namespace)
results = []
for t_ident in tables:
qualified = qualified_table_name(t_ident)
results.extend(self.run_for_table(qualified, rule_ids, type))
if recursive:
nested_namespaces = self.lakeview._get_nested_namespaces(namespace)
ns = tuple(namespace.split('.'))
nested_namespaces = self.lakeview._get_nested_namespaces(ns, len(ns))
for ns in nested_namespaces:
ns_str = ".".join(ns)
results.extend(self.run_for_namespace(ns_str, rule_ids, recursive=False, type=type))
results.extend(self.run_for_namespace(ns_str, rule_ids, recursive=recursive, type=type))
return results

def run_for_lakehouse(self, rule_ids: List[str] = None, type: str = "manual") -> Dict[str, List[Insight]]:
Expand Down
7 changes: 6 additions & 1 deletion fe/src/routes/+layout.svelte
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
let AUTH_ENABLED = false;
let CHAT_ENABLED = false;
let CHAT_NAME = 'Chat';
let CHAT_DESCRIPTION = '';
let extra_link;
let extra_link_text;
let company = 'Apache Iceberg';
Expand Down Expand Up @@ -75,6 +76,9 @@
if (env.PUBLIC_CHAT_NAME) {
CHAT_NAME = env.PUBLIC_CHAT_NAME;
}
if (env.PUBLIC_CHAT_DESCRIPTION) {
CHAT_DESCRIPTION = env.PUBLIC_CHAT_DESCRIPTION;
}
CHAT_ENABLED = true;
}
if (env.PUBLIC_EXTRA_LINK) {
Expand Down Expand Up @@ -201,11 +205,12 @@
size='lg'
passiveModal
bind:open={isChatOpen}
modalHeading="{CHAT_NAME} - Chat with your Lakehouse"
modalHeading="{CHAT_NAME}"
on:open={handleChatOpen}
on:close={handleChatClose}
on:click:overlay={handleChatClose}
>
<p>{CHAT_DESCRIPTION}</p>
{#if user}
<Chat {user} />
{/if}
Expand Down
4 changes: 3 additions & 1 deletion my.env
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,7 @@ AUTHZ_CLASS_NAME=
#Chat config
PUBLIC_CHAT_ENABLED=false
PUBLIC_CHAT_NAME=Chat
PUBLIC_CHAT_DESCRIPTION=Chat with your Lakehouse
PUBLIC_CHAT_SERVER=ws://localhost:8000/ws

#Any extra link we want to put, would go in top right app selector
Expand All @@ -50,4 +51,5 @@ PUBLIC_EXTRA_LINK_TEXT=
PUBLIC_COMPANY_NAME="Apache Iceberg"
PUBLIC_PLATFORM_NAME=Lakehouse


#Database for storing insights and future features
DATABASE_URL=postgresql://<user>:<psw>@<host>:<port>/dbname