File tree Expand file tree Collapse file tree 1 file changed +9
-3
lines changed
Expand file tree Collapse file tree 1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change 88from typing import Union
99
1010from util .datasets_json_util import DatasetsJson
11-
11+ from util . job_util import is_running_outside_verdi_worker_context
1212
1313logger = logging .getLogger (__name__ )
1414
@@ -42,15 +42,21 @@ def make_dataset_dir(dataset_id, dataset_type: str = None):
4242
4343
4444def validate_dataset_type (dataset_type ):
45- datasets_json = DatasetsJson (file = "datasets.json" )
45+ if is_running_outside_verdi_worker_context ():
46+ datasets_json = DatasetsJson (file = "datasets.json" )
47+ else :
48+ datasets_json = DatasetsJson ()
4649 try :
4750 datasets_json .get (dataset_type )
4851 except KeyError as e :
4952 raise Exception (f"Invalid { dataset_type = } . Compare against datasets.json" ) from e
5053
5154
5255def is_valid_dataset_type (dataset_type = None ):
53- datasets_json = DatasetsJson (file = "datasets.json" )
56+ if is_running_outside_verdi_worker_context ():
57+ datasets_json = DatasetsJson (file = "datasets.json" )
58+ else :
59+ datasets_json = DatasetsJson ()
5460 try :
5561 datasets_json .get (dataset_type )
5662 return True
You can’t perform that action at this time.
0 commit comments