Loading csst_common/data_manager.py +3 −2 Original line number Original line Diff line number Diff line Loading @@ -18,7 +18,6 @@ import os import re import re from typing import Union from typing import Union import joblib import numpy as np import numpy as np from astropy.io import fits from astropy.io import fits from astropy.table import Table from astropy.table import Table Loading Loading @@ -693,6 +692,8 @@ def test_dm(): import joblib import joblib from csst_common.data_manager import CsstMsDataManager from csst_common.data_manager import CsstMsDataManager dm = CsstMsDataManager(dfs_node="pml") dm = CsstMsDataManager(dfs_node="pml") def f(dm, a=1): def f(dm, a=1): print(a) print(a) joblib.Parallel(n_jobs=10, )(joblib.delayed(f)(dm) for i in range(10)) joblib.Parallel(n_jobs=10, )(joblib.delayed(f)(dm) for i in range(10)) Loading
csst_common/data_manager.py +3 −2 Original line number Original line Diff line number Diff line Loading @@ -18,7 +18,6 @@ import os import re import re from typing import Union from typing import Union import joblib import numpy as np import numpy as np from astropy.io import fits from astropy.io import fits from astropy.table import Table from astropy.table import Table Loading Loading @@ -693,6 +692,8 @@ def test_dm(): import joblib import joblib from csst_common.data_manager import CsstMsDataManager from csst_common.data_manager import CsstMsDataManager dm = CsstMsDataManager(dfs_node="pml") dm = CsstMsDataManager(dfs_node="pml") def f(dm, a=1): def f(dm, a=1): print(a) print(a) joblib.Parallel(n_jobs=10, )(joblib.delayed(f)(dm) for i in range(10)) joblib.Parallel(n_jobs=10, )(joblib.delayed(f)(dm) for i in range(10))