Skip to content

Commit 7b45a51

Browse files
committed
fix: tests on resources
1 parent ee6a074 commit 7b45a51

1 file changed

Lines changed: 57 additions & 41 deletions

File tree

tests/test_api_analysis.py

Lines changed: 57 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
from datashield import DSSession, DSLoginBuilder
1+
from datashield import DSSession, DSLoginBuilder, DSError
22

33

44
class TestClass:
@@ -14,49 +14,65 @@ def teardown_method(self, method):
1414
self.session.close()
1515

1616
def test_assign_tables(self):
17-
self.session.assign_table(
18-
"df", tables={"server1": "CNSIM.CNSIM1", "server2": "CNSIM.CNSIM2"}, asynchronous=False
19-
)
20-
rval = self.session.ls()
21-
assert len(rval) == 2
22-
assert "server1" in rval
23-
assert rval["server1"] == ["df"]
24-
assert "server2" in rval
25-
assert rval["server2"] == ["df"]
17+
try:
18+
self.session.assign_table(
19+
"df", tables={"server1": "CNSIM.CNSIM1", "server2": "CNSIM.CNSIM2"}, asynchronous=False
20+
)
21+
rval = self.session.ls()
22+
assert len(rval) == 2
23+
assert "server1" in rval
24+
assert rval["server1"] == ["df"]
25+
assert "server2" in rval
26+
assert rval["server2"] == ["df"]
27+
except DSError as e:
28+
print(self.session.get_errors())
29+
raise ValueError("Failed to assign tables") from e
2630

2731
def test_assign_table(self):
28-
self.session.assign_table("df", table="CNSIM.CNSIM1", asynchronous=False)
29-
rval = self.session.ls()
30-
assert len(rval) == 2
31-
assert "server1" in rval
32-
assert rval["server1"] == ["df"]
33-
assert "server2" in rval
34-
assert rval["server2"] == ["df"]
32+
try:
33+
self.session.assign_table("df", table="CNSIM.CNSIM1", asynchronous=False)
34+
rval = self.session.ls()
35+
assert len(rval) == 2
36+
assert "server1" in rval
37+
assert rval["server1"] == ["df"]
38+
assert "server2" in rval
39+
assert rval["server2"] == ["df"]
40+
except DSError as e:
41+
print(self.session.get_errors())
42+
raise ValueError("Failed to assign table") from e
3543

3644
def test_assign_resources(self):
37-
self.session.assign_resource(
38-
"client", resources={"server1": "RSRC.CNSIM1", "server2": "RSRC.CNSIM2"}, asynchronous=False
39-
)
40-
rval = self.session.ls()
41-
assert len(rval) == 2
42-
assert "server1" in rval
43-
assert rval["server1"] == ["client"]
44-
assert "server2" in rval
45-
assert rval["server2"] == ["client"]
46-
47-
self.session.assign_expr("df", "as.resource.data.frame(client, strict = TRUE)", asynchronous=False)
48-
rval = self.session.ls()
49-
assert len(rval) == 2
50-
assert "server1" in rval
51-
assert len(rval["server1"]) == 2
52-
assert "client" in rval["server1"]
53-
assert "df" in rval["server1"]
45+
try:
46+
self.session.assign_resource(
47+
"client", resources={"server1": "RSRC.CNSIM1", "server2": "RSRC.CNSIM1"}, asynchronous=False
48+
)
49+
rval = self.session.ls()
50+
assert len(rval) == 2
51+
assert "server1" in rval
52+
assert rval["server1"] == ["client"]
53+
assert "server2" in rval
54+
assert rval["server2"] == ["client"]
55+
56+
self.session.assign_expr("df", "as.resource.data.frame(client, strict = TRUE)", asynchronous=False)
57+
rval = self.session.ls()
58+
assert len(rval) == 2
59+
assert "server1" in rval
60+
assert len(rval["server1"]) == 2
61+
assert "client" in rval["server1"]
62+
assert "df" in rval["server1"]
63+
except DSError as e:
64+
print(self.session.get_errors())
65+
raise ValueError("Failed to assign resources") from e
5466

5567
def test_assign_resource(self):
56-
self.session.assign_resource("client", resource="RSRC.CNSIM1", asynchronous=False)
57-
rval = self.session.ls()
58-
assert len(rval) == 2
59-
assert "server1" in rval
60-
assert rval["server1"] == ["client"]
61-
assert "server2" in rval
62-
assert rval["server2"] == ["client"]
68+
try:
69+
self.session.assign_resource("client", resource="RSRC.CNSIM1", asynchronous=False)
70+
rval = self.session.ls()
71+
assert len(rval) == 2
72+
assert "server1" in rval
73+
assert rval["server1"] == ["client"]
74+
assert "server2" in rval
75+
assert rval["server2"] == ["client"]
76+
except DSError as e:
77+
print(self.session.get_errors())
78+
raise ValueError("Failed to assign resource") from e

0 commit comments

Comments
 (0)