Skip to content
This repository was archived by the owner on Feb 2, 2024. It is now read-only.

Commit aaa9730

Browse files
author
Ehsan Totoni
committed
utils to count array parfor 1d/rep
1 parent 801692f commit aaa9730

2 files changed

Lines changed: 27 additions & 0 deletions

File tree

hpat/tests/test_hiframes.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,8 @@
22
import pandas as pd
33
import numpy as np
44
import hpat
5+
from hpat.tests.test_utils import (count_array_REPs, count_parfor_REPs,
6+
count_parfor_OneDs, count_array_OneDs)
57

68
class TestHiFrames(unittest.TestCase):
79
def test_cumsum(self):
@@ -13,6 +15,10 @@ def test_impl(n):
1315
hpat_func = hpat.jit(test_impl)
1416
n = 11
1517
self.assertEqual(hpat_func(n), test_impl(n))
18+
self.assertEqual(count_array_REPs(), 0)
19+
self.assertEqual(count_array_OneDs(), 2)
20+
self.assertEqual(count_parfor_REPs(), 0)
21+
self.assertEqual(count_parfor_OneDs(), 2)
1622

1723
if __name__ == "__main__":
1824
unittest.main()

hpat/tests/test_utils.py

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
import hpat
2+
3+
def count_array_REPs():
4+
from hpat.distributed import Distribution
5+
vals = hpat.distributed.dist_analysis.array_dists.values()
6+
return sum([v==Distribution.REP for v in vals])
7+
8+
def count_parfor_REPs():
9+
from hpat.distributed import Distribution
10+
vals = hpat.distributed.dist_analysis.parfor_dists.values()
11+
return sum([v==Distribution.REP for v in vals])
12+
13+
def count_parfor_OneDs():
14+
from hpat.distributed import Distribution
15+
vals = hpat.distributed.dist_analysis.parfor_dists.values()
16+
return sum([v==Distribution.OneD for v in vals])
17+
18+
def count_array_OneDs():
19+
from hpat.distributed import Distribution
20+
vals = hpat.distributed.dist_analysis.array_dists.values()
21+
return sum([v==Distribution.OneD for v in vals])

0 commit comments

Comments
 (0)