Skip to content

Commit 742ecac

Browse files
authored
add tests on new performance params and get_latest_result (#58)
* add tests * naming fix
1 parent 1249203 commit 742ecac

File tree

2 files changed

+30
-0
lines changed

2 files changed

+30
-0
lines changed

tests/e2e/test_async_client.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,21 @@ async def test_refresh_context_manager(self):
3333
results = (await cl.refresh(self.query)).get_rows()
3434
self.assertGreater(len(results), 0)
3535

36+
async def test_refresh_context_manager_performance_large(self):
37+
async with AsyncDuneClient(self.valid_api_key) as cl:
38+
results = (await cl.refresh(self.query, performance="large")).get_rows()
39+
self.assertGreater(len(results), 0)
40+
41+
async def test_get_latest_result_with_query_object(self):
42+
async with AsyncDuneClient(self.valid_api_key) as cl:
43+
results = (await cl.get_latest_result(self.query)).get_rows()
44+
self.assertGreater(len(results), 0)
45+
46+
async def test_get_latest_result_with_query_id(self):
47+
async with AsyncDuneClient(self.valid_api_key) as cl:
48+
results = (await cl.get_latest_result(self.query.query_id)).get_rows()
49+
self.assertGreater(len(results), 0)
50+
3651

3752
if __name__ == "__main__":
3853
unittest.main()

tests/e2e/test_client.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,11 @@ def test_refresh(self):
4545
results = dune.refresh(self.query).get_rows()
4646
self.assertGreater(len(results), 0)
4747

48+
def test_refresh_performance_large(self):
49+
dune = DuneClient(self.valid_api_key)
50+
results = dune.refresh(self.query, performance="large").get_rows()
51+
self.assertGreater(len(results), 0)
52+
4853
def test_refresh_into_dataframe(self):
4954
dune = DuneClient(self.valid_api_key)
5055
pd = dune.refresh_into_dataframe(self.query)
@@ -160,6 +165,16 @@ def test_invalid_job_id_error(self):
160165
"{'error': 'The requested execution ID (ID: Wonky Job ID) is invalid.'}",
161166
)
162167

168+
def test_get_latest_result_with_query_object(self):
169+
dune = DuneClient(self.valid_api_key)
170+
results = dune.get_latest_result(self.query).get_rows()
171+
self.assertGreater(len(results), 0)
172+
173+
def test_get_latest_result_with_query_id(self):
174+
dune = DuneClient(self.valid_api_key)
175+
results = dune.get_latest_result(self.query.query_id).get_rows()
176+
self.assertGreater(len(results), 0)
177+
163178

164179
if __name__ == "__main__":
165180
unittest.main()

0 commit comments

Comments
 (0)