@@ -1251,7 +1251,8 @@ def test_list(self, mock_get):
1251
1251
'skills' : [],
1252
1252
'params' : {},
1253
1253
'created_at' : created_at ,
1254
- 'updated_at' : updated_at
1254
+ 'updated_at' : updated_at ,
1255
+ 'provider' : 'mindsdb'
1255
1256
}
1256
1257
])
1257
1258
all_agents = server .agents .list ()
@@ -1265,7 +1266,8 @@ def test_list(self, mock_get):
1265
1266
[],
1266
1267
{},
1267
1268
created_at ,
1268
- updated_at
1269
+ updated_at ,
1270
+ 'mindsdb'
1269
1271
)
1270
1272
assert all_agents [0 ] == expected_agent
1271
1273
@@ -1283,7 +1285,8 @@ def test_get(self, mock_get):
1283
1285
'skills' : [],
1284
1286
'params' : {},
1285
1287
'created_at' : created_at ,
1286
- 'updated_at' : updated_at
1288
+ 'updated_at' : updated_at ,
1289
+ 'provider' : 'mindsdb'
1287
1290
}
1288
1291
)
1289
1292
agent = server .agents .get ('test_agent' )
@@ -1295,7 +1298,8 @@ def test_get(self, mock_get):
1295
1298
[],
1296
1299
{},
1297
1300
created_at ,
1298
- updated_at
1301
+ updated_at ,
1302
+ 'mindsdb'
1299
1303
)
1300
1304
assert agent == expected_agent
1301
1305
@@ -1318,7 +1322,8 @@ def test_create(self, mock_get, mock_post):
1318
1322
}],
1319
1323
'params' : {'k1' : 'v1' },
1320
1324
'created_at' : created_at ,
1321
- 'updated_at' : updated_at
1325
+ 'updated_at' : updated_at ,
1326
+ 'provider' : 'mindsdb' ,
1322
1327
}
1323
1328
responses_mock (mock_post , [
1324
1329
# ML Engine get (SQL post for SHOW ML_ENGINES)
@@ -1344,9 +1349,10 @@ def test_create(self, mock_get, mock_post):
1344
1349
assert mock_post .call_args_list [- 1 ][1 ]['json' ] == {
1345
1350
'agent' : {
1346
1351
'name' : 'test_agent' ,
1347
- 'model_name' :'m1' ,
1352
+ 'model_name' : 'm1' ,
1348
1353
'skills' : ['test_skill' ],
1349
- 'params' : {'k1' : 'v1' }
1354
+ 'params' : {'k1' : 'v1' },
1355
+ 'provider' : None
1350
1356
}
1351
1357
}
1352
1358
expected_skill = SQLSkill ('test_skill' , ['test_table' ], 'test_database' , 'test_description' )
@@ -1356,7 +1362,8 @@ def test_create(self, mock_get, mock_post):
1356
1362
[expected_skill ],
1357
1363
{'k1' : 'v1' },
1358
1364
created_at ,
1359
- updated_at
1365
+ updated_at ,
1366
+ 'mindsdb'
1360
1367
)
1361
1368
1362
1369
assert new_agent == expected_agent
@@ -1383,7 +1390,8 @@ def test_update(self, mock_get, mock_put, _):
1383
1390
}],
1384
1391
'params' : {'k2' : 'v2' },
1385
1392
'created_at' : created_at ,
1386
- 'updated_at' : updated_at
1393
+ 'updated_at' : updated_at ,
1394
+ 'provider' : 'mindsdb' ,
1387
1395
}
1388
1396
response_mock (mock_put , data )
1389
1397
@@ -1395,6 +1403,7 @@ def test_update(self, mock_get, mock_put, _):
1395
1403
'model_name' : 'test_model' ,
1396
1404
'skills' : [],
1397
1405
'params' : {'k1' : 'v1' },
1406
+ 'provider' : 'mindsdb' ,
1398
1407
})
1399
1408
1400
1409
server = mindsdb_sdk .connect ()
@@ -1404,7 +1413,8 @@ def test_update(self, mock_get, mock_put, _):
1404
1413
[SQLSkill ('updated_skill' , ['updated_table' ], 'updated_database' , 'test_description' )],
1405
1414
{'k2' : 'v2' },
1406
1415
created_at ,
1407
- updated_at
1416
+ updated_at ,
1417
+ 'mindsdb'
1408
1418
)
1409
1419
1410
1420
updated_agent = server .agents .update ('test_agent' , expected_agent )
@@ -1467,7 +1477,8 @@ def test_add_file(self, mock_post, mock_put, mock_get):
1467
1477
'skills' : [],
1468
1478
'params' : {},
1469
1479
'created_at' : None ,
1470
- 'updated_at' : None
1480
+ 'updated_at' : None ,
1481
+ 'provider' : 'mindsdb'
1471
1482
},
1472
1483
# Skills get in Agent update to check if it exists.
1473
1484
{'name' : 'new_skill' , 'type' : 'retrieval' , 'params' : {'source' : 'test_agent_tokaido_rules_kb' }},
@@ -1478,7 +1489,8 @@ def test_add_file(self, mock_post, mock_put, mock_get):
1478
1489
'skills' : [],
1479
1490
'params' : {},
1480
1491
'created_at' : None ,
1481
- 'updated_at' : None
1492
+ 'updated_at' : None ,
1493
+ 'provider' : 'mindsdb'
1482
1494
},
1483
1495
])
1484
1496
responses_mock (mock_post , [
@@ -1499,7 +1511,8 @@ def test_add_file(self, mock_post, mock_put, mock_get):
1499
1511
'skills' : [{'name' : 'new_skill' , 'type' : 'retrieval' , 'params' : {'source' : 'test_agent_tokaido_rules_kb' }}],
1500
1512
'params' : {},
1501
1513
'created_at' : None ,
1502
- 'updated_at' : None
1514
+ 'updated_at' : None ,
1515
+ 'provider' : 'mindsdb'
1503
1516
},
1504
1517
])
1505
1518
server .agents .add_file ('test_agent' , './tokaido_rules.pdf' , 'Rules for the board game Tokaido' , 'existing_kb' )
@@ -1518,7 +1531,6 @@ def test_add_file(self, mock_post, mock_put, mock_get):
1518
1531
}
1519
1532
assert agent_update_json == expected_agent_json
1520
1533
1521
-
1522
1534
@patch ('requests.Session.get' )
1523
1535
@patch ('requests.Session.put' )
1524
1536
@patch ('requests.Session.post' )
@@ -1527,58 +1539,61 @@ def test_add_webpage(self, mock_post, mock_put, mock_get):
1527
1539
responses_mock (mock_get , [
1528
1540
# Existing agent get.
1529
1541
{
1530
- 'name' : 'test_agent' ,
1531
- 'model_name' : 'test_model' ,
1532
- 'skills' : [],
1533
- 'params' : {},
1534
- 'created_at' : None ,
1535
- 'updated_at' : None
1542
+ 'name' :'test_agent' ,
1543
+ 'model_name' :'test_model' ,
1544
+ 'skills' :[],
1545
+ 'params' :{},
1546
+ 'created_at' :None ,
1547
+ 'updated_at' :None ,
1548
+ 'provider' :'mindsdb'
1536
1549
},
1537
1550
# Skills get in Agent update to check if it exists.
1538
- {'name' : 'new_skill' , 'type' : 'retrieval' , 'params' : {'source' : 'test_agent_docs_mdb_ai_kb' }},
1551
+ {'name' :'new_skill' , 'type' :'retrieval' , 'params' :{'source' :'test_agent_docs_mdb_ai_kb' }},
1539
1552
# Existing agent get in Agent update.
1540
1553
{
1541
- 'name' : 'test_agent' ,
1542
- 'model_name' : 'test_model' ,
1543
- 'skills' : [],
1544
- 'params' : {},
1545
- 'created_at' : None ,
1546
- 'updated_at' : None
1554
+ 'name' :'test_agent' ,
1555
+ 'model_name' :'test_model' ,
1556
+ 'skills' :[],
1557
+ 'params' :{},
1558
+ 'created_at' :None ,
1559
+ 'updated_at' :None ,
1560
+ 'provider' :'mindsdb' # Added provider field
1547
1561
},
1548
1562
])
1549
1563
responses_mock (mock_post , [
1550
1564
# KB get (POST /sql).
1551
1565
pd .DataFrame ([
1552
- {'name' : 'test_agent_docs_mdb_ai_kb' , 'storage' : None , 'model' : None },
1566
+ {'name' :'test_agent_docs_mdb_ai_kb' , 'storage' :None , 'model' :None },
1553
1567
]),
1554
1568
# Skill creation.
1555
- {'name' : 'new_skill' , 'type' : 'retrieval' , 'params' : {'source' : 'test_agent_docs_mdb_ai_kb' }}
1569
+ {'name' :'new_skill' , 'type' :'retrieval' , 'params' :{'source' :'test_agent_docs_mdb_ai_kb' }}
1556
1570
])
1557
1571
responses_mock (mock_put , [
1558
1572
# KB update.
1559
- {'name' : 'test_agent_docs_mdb_ai_kb' },
1573
+ {'name' :'test_agent_docs_mdb_ai_kb' },
1560
1574
# Agent update with new skill.
1561
1575
{
1562
- 'name' : 'test_agent' ,
1563
- 'model_name' : 'test_model' ,
1564
- 'skills' : [{'name' : 'new_skill' , 'type' : 'retrieval' , 'params' : {'source' : 'test_agent_docs_mdb_ai_kb' }}],
1565
- 'params' : {},
1566
- 'created_at' : None ,
1567
- 'updated_at' : None
1576
+ 'name' :'test_agent' ,
1577
+ 'model_name' :'test_model' ,
1578
+ 'skills' :[{'name' :'new_skill' , 'type' :'retrieval' , 'params' :{'source' :'test_agent_docs_mdb_ai_kb' }}],
1579
+ 'params' :{},
1580
+ 'created_at' :None ,
1581
+ 'updated_at' :None ,
1582
+ 'provider' :'mindsdb' # Added provider field
1568
1583
},
1569
1584
])
1570
1585
server .agents .add_webpage ('test_agent' , 'docs.mdb.ai' , 'Documentation for MindsDB' , 'existing_kb' )
1571
1586
1572
1587
# Check Agent was updated with a new skill.
1573
1588
agent_update_json = mock_put .call_args [- 1 ]['json' ]
1574
1589
expected_agent_json = {
1575
- 'agent' : {
1576
- 'name' : 'test_agent' ,
1577
- 'model_name' : 'test_model' ,
1590
+ 'agent' :{
1591
+ 'name' :'test_agent' ,
1592
+ 'model_name' :'test_model' ,
1578
1593
# Skill name is a generated UUID.
1579
- 'skills_to_add' : [agent_update_json ['agent' ]['skills_to_add' ][0 ]],
1580
- 'skills_to_remove' : [],
1581
- 'params' : {},
1594
+ 'skills_to_add' :[agent_update_json ['agent' ]['skills_to_add' ][0 ]],
1595
+ 'skills_to_remove' :[],
1596
+ 'params' :{},
1582
1597
}
1583
1598
}
1584
1599
assert agent_update_json == expected_agent_json
@@ -1596,7 +1611,8 @@ def test_add_database(self, mock_post, mock_put, mock_get):
1596
1611
'skills' : [],
1597
1612
'params' : {},
1598
1613
'created_at' : None ,
1599
- 'updated_at' : None
1614
+ 'updated_at' : None ,
1615
+ 'provider' : 'mindsdb'
1600
1616
},
1601
1617
# Skills get in Agent update to check if it exists.
1602
1618
{'name' : 'new_skill' , 'type' : 'sql' , 'params' : {'database' : 'existing_db' , 'tables' : ['existing_table' ]}},
@@ -1607,7 +1623,8 @@ def test_add_database(self, mock_post, mock_put, mock_get):
1607
1623
'skills' : [],
1608
1624
'params' : {},
1609
1625
'created_at' : None ,
1610
- 'updated_at' : None
1626
+ 'updated_at' : None ,
1627
+ 'provider' : 'mindsdb'
1611
1628
},
1612
1629
])
1613
1630
responses_mock (mock_post , [
@@ -1630,7 +1647,8 @@ def test_add_database(self, mock_post, mock_put, mock_get):
1630
1647
'skills' : [{'name' : 'new_skill' , 'type' : 'sql' , 'params' : {'database' : 'existing_db' , 'tables' : ['existing_table' ]}}],
1631
1648
'params' : {},
1632
1649
'created_at' : None ,
1633
- 'updated_at' : None
1650
+ 'updated_at' : None ,
1651
+ 'provider' : 'mindsdb'
1634
1652
},
1635
1653
])
1636
1654
server .agents .add_database ('test_agent' , 'existing_db' , ['existing_table' ], 'My data' )
@@ -1644,7 +1662,7 @@ def test_add_database(self, mock_post, mock_put, mock_get):
1644
1662
# Skill name is a generated UUID.
1645
1663
'skills_to_add' : [agent_update_json ['agent' ]['skills_to_add' ][0 ]],
1646
1664
'skills_to_remove' : [],
1647
- 'params' : {},
1665
+ 'params' : {'prompt_template' : 'using mindsdb sqltoolbox' },
1648
1666
}
1649
1667
}
1650
1668
assert agent_update_json == expected_agent_json
0 commit comments