Skip to content

Commit 6cad5ef

Browse files
fix: add default etl_config_id getters (#204)
1 parent 5d9b051 commit 6cad5ef

File tree

2 files changed

+18
-0
lines changed

2 files changed

+18
-0
lines changed

cognition_objects/markdown_dataset.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,15 @@ def get_dataset_count_dict(org_id: str) -> Dict[str, int]:
136136
raise Exception("No results found")
137137

138138

139+
def get_default_etl_config_id(org_id: str, dataset_id: str) -> Optional[str]:
140+
dataset = get(org_id, dataset_id)
141+
if dataset and dataset.useable_etl_configurations:
142+
for config in dataset.useable_etl_configurations:
143+
if config.get("isDefault"):
144+
return config.get("id")
145+
raise ValueError(f"No default ETL config found for dataset {dataset_id}")
146+
147+
139148
def create(
140149
org_id: str,
141150
created_by: str,

cognition_objects/project.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,15 @@ def get_project_users_overview(
147147
return {}
148148

149149

150+
def get_default_etl_config_id(project_id: str) -> Optional[str]:
151+
project = get_cached(project_id)
152+
if project and project.useable_etl_configurations:
153+
for config in project.useable_etl_configurations:
154+
if config.get("isDefault"):
155+
return config.get("id")
156+
raise ValueError(f"No default ETL config found for project {project_id}")
157+
158+
150159
ROUTING_SOURCE_CODE_DEFAULT_BLANK = """from typing import Dict, Any, Tuple
151160
def routing(
152161
record_dict: Dict[str, Any], scope_dict: Dict[str, Any]

0 commit comments

Comments
 (0)