py-wake
Advanced tools
+1
-1
| Metadata-Version: 2.4 | ||
| Name: py_wake | ||
| Version: 2.6.17 | ||
| Version: 2.6.18 | ||
| Summary: Open source static wake modeling framework from DTU | ||
@@ -5,0 +5,0 @@ Author: DTU Wind Energy |
@@ -51,1 +51,5 @@ import time | ||
| assert np.min(t) < 0.5 | ||
| map_func = get_map_func(n_cpu=None, starmap=False, verbose=False) | ||
| t = timeit(lambda x: list(map_func(f, x)), min_runs=3)(np.arange(6))[1] | ||
| assert np.min(t) < 0.5 |
@@ -7,9 +7,13 @@ import atexit | ||
| try: # pragma: no cover | ||
| from mpi4py import MPI | ||
| comm = MPI.COMM_WORLD | ||
| assert comm.Get_size() > 1 | ||
| except (ImportError, AssertionError): | ||
| MPI = None | ||
| def load_MPI(): | ||
| try: # pragma: no cover | ||
| from mpi4py import MPI | ||
| comm = MPI.COMM_WORLD | ||
| assert comm.Get_size() > 1 | ||
| except (ImportError, AssertionError): | ||
| MPI = None | ||
| return MPI | ||
| pool_dict = {} | ||
@@ -65,2 +69,3 @@ | ||
| def get_n_cpu(n_cpu): | ||
| MPI = load_MPI() | ||
| if MPI is None: | ||
@@ -75,5 +80,8 @@ n_cpu = n_cpu or multiprocessing.cpu_count() | ||
| def get_map_func(n_cpu, starmap=False, verbose=True, desc='', unit='it', leave=True): | ||
| n_cpu = get_n_cpu(n_cpu) | ||
| if n_cpu is None: | ||
| n_cpu = get_n_cpu(n_cpu) | ||
| if n_cpu > 1: | ||
| n_cpu = get_n_cpu(n_cpu) | ||
| MPI = load_MPI() | ||
| if MPI and n_cpu > 1: # pragma: no cover | ||
@@ -105,2 +113,3 @@ map_func = get_mpi_map_func(n_cpu, starmap=starmap) | ||
| def get_mpi_map_func(n_cpu, starmap=False): # pragma: no cover | ||
| MPI = load_MPI() | ||
| assert MPI is not None, "mpi4py is not installed" | ||
@@ -107,0 +116,0 @@ comm = MPI.COMM_WORLD |
@@ -31,5 +31,5 @@ # file generated by setuptools-scm | ||
| __version__ = version = '2.6.17' | ||
| __version_tuple__ = version_tuple = (2, 6, 17) | ||
| __version__ = version = '2.6.18' | ||
| __version_tuple__ = version_tuple = (2, 6, 18) | ||
| __commit_id__ = commit_id = None |
+8
-8
@@ -9,3 +9,3 @@ docs/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0 | ||
| py_wake/superposition_models.py,sha256=wJ-JJElwdWiNOwv1v0NXjbTV1ZbbBSmC-GJziO1YPJs,10669 | ||
| py_wake/version.py,sha256=NauhVIERykrLkuAo4rI2RyJQXOSgmqEnQesJmE0DWyY,706 | ||
| py_wake/version.py,sha256=KNVa8zi0dOmLXNcGcJ8wLrs5TVLuqMMpRIpCkCHGrMI,706 | ||
| py_wake/deficit_models/__init__.py,sha256=w1S4F3FmAgtwqGO90fASYoqxOb6SsgjbasiD3V8_1uk,709 | ||
@@ -361,3 +361,3 @@ py_wake/deficit_models/deficit_model.py,sha256=ly8A6pZQ6kt39fzsAz9OVw_5ohr7b26I5iHRYni2QrM,10466 | ||
| py_wake/tests/test_utils/test_numpy.py,sha256=-1w5XJjZQDbRjLt9sRbico_ziNK3_4VsrYkY1czNlpg,7536 | ||
| py_wake/tests/test_utils/test_parallelization.py,sha256=JZM9iYxmiY8KnDw0ZqKfDWIOhU-LeVDuXYmXxnd34x0,1520 | ||
| py_wake/tests/test_utils/test_parallelization.py,sha256=UpDGcA9IEijbkK7OHblo7F-FSw5dyaOUyVGfYTmlHAo,1694 | ||
| py_wake/tests/test_utils/test_plotting.py,sha256=tCmEUdvZinzcFMiBGRth8MbFKuVSxQFDuPNh762GBps,286 | ||
@@ -409,3 +409,3 @@ py_wake/tests/test_utils/test_profiling.py,sha256=jwanMam7pqEVzlKdsjKqDzWJN1Y7PqY0RN6FqYggNIk,1558 | ||
| py_wake/utils/numpy_utils.py,sha256=I9URsvF0ALXOFwdlkTK-mQLul0d-5wLjSWuEeAmE5ZU,3192 | ||
| py_wake/utils/parallelization.py,sha256=aHT3B1pIC6YYWZqUAclW1VzMCroblqnwwoebsImFaB8,3693 | ||
| py_wake/utils/parallelization.py,sha256=aFzRglfLqT6Iq9LoKTae6sXeQjYCPm-gHqzS5cuxF38,3876 | ||
| py_wake/utils/plotting.py,sha256=zXharIIWIwl-E0Xh2JP3qAnYEEAKGJidQcldhRd0dRo,568 | ||
@@ -434,6 +434,6 @@ py_wake/utils/profiling.py,sha256=g6aDNtZg_7lcxUg4WdAawGMysaoZW87iPyTWwiPvWdA,4668 | ||
| py_wake/wind_turbines/wind_turbines_deprecated.py,sha256=HpNmBR8CJL4-8JBaygDI0t086qfw5bR2DOQI8Ox4AZ4,6250 | ||
| py_wake-2.6.17.dist-info/licenses/LICENSE,sha256=XE2CGPqQgzSXqIajXpAVYJ5SRNmaWOIeMePK6MocsuY,1084 | ||
| py_wake-2.6.17.dist-info/METADATA,sha256=bA0FK31ceJP7fXVWs2kbF5heDUstSVqr3ZgQmmbYy_E,3760 | ||
| py_wake-2.6.17.dist-info/WHEEL,sha256=_zCd3N1l69ArxyTb8rzEoP9TpbYXkqRFSNOD5OuxnTs,91 | ||
| py_wake-2.6.17.dist-info/top_level.txt,sha256=GsaXU4YwyMkZZ6dkb4h0FMc5RaLIT2Qns_YoScKoXdk,20 | ||
| py_wake-2.6.17.dist-info/RECORD,, | ||
| py_wake-2.6.18.dist-info/licenses/LICENSE,sha256=XE2CGPqQgzSXqIajXpAVYJ5SRNmaWOIeMePK6MocsuY,1084 | ||
| py_wake-2.6.18.dist-info/METADATA,sha256=PU1ObxsVwOxG6HK1VKxC0elqe99jXDW6Y3N3ehSUiOw,3760 | ||
| py_wake-2.6.18.dist-info/WHEEL,sha256=_zCd3N1l69ArxyTb8rzEoP9TpbYXkqRFSNOD5OuxnTs,91 | ||
| py_wake-2.6.18.dist-info/top_level.txt,sha256=GsaXU4YwyMkZZ6dkb4h0FMc5RaLIT2Qns_YoScKoXdk,20 | ||
| py_wake-2.6.18.dist-info/RECORD,, |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.