Skip to content

Commit c65d9fe

Browse files
authored
Merge pull request #4 from mindsdb/replace-ds
Create or replace for datasource
2 parents e337bd7 + fd89561 commit c65d9fe

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

examples/base_usage.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,10 @@
7373

7474
# --- managing datasources ---
7575

76+
# create or replace
77+
datasource = client.datasources.create(postgres_config, replace=True)
78+
79+
7680
# list
7781
print(client.datasources.list())
7882

minds/datasources/datasources.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,15 @@ class Datasources:
2020
def __init__(self, client):
2121
self.api = client.api
2222

23-
def create(self, ds_config: DatabaseConfig):
23+
def create(self, ds_config: DatabaseConfig, replace=False):
2424
name = ds_config.name
25+
26+
if replace:
27+
try:
28+
self.drop(name)
29+
except Exception:
30+
...
31+
2532
self.api.post('/datasources', data=ds_config.model_dump())
2633
return self.get(name)
2734

0 commit comments

Comments
 (0)