@@ -230,7 +230,7 @@ def _init_stream_datasets(
230230 streams_datasets : dict [StreamName , _Stream ] = {}
231231 for stream_name , stream_info in cf .streams .items ():
232232 stream_info ["data_paths" ] = cf .get ("data_paths" , [])
233- ds_type = stream_info ["type" ]
233+ ds_type = stream_info ["type" ]
234234 # list of sources for current stream
235235 streams_datasets [stream_name ] = _Stream (stream_info , [])
236236 kwargs = {
@@ -251,11 +251,19 @@ def _init_stream_datasets(
251251 f"for stream name '{ stream_name } '."
252252 raise ValueError (msg )
253253
254- for fname in stream_info .get ("filenames" , [pathlib .Path ()]):
254+ filenames_cfg = stream_info .get ("filenames" , [pathlib .Path ()])
255+
256+ if filenames_cfg is None :
257+ filenames_cfg = [pathlib .Path ()]
258+ else :
259+ pass
260+
261+
262+ for fname in filenames_cfg :
255263 fname = pathlib .Path (fname )
256264 # skip if explicitly pointing to current directory
257- if fname is None or fname == pathlib .Path ():
258- if dataset . conditioning :
265+ if fname == pathlib .Path ():
266+ if stream_info . get ( " conditioning" , False ) :
259267 if is_root ():
260268 logger .info (
261269 f"Opening conditioning dataset with type: { ds_type } "
0 commit comments