31
31
from reframe .core .warnings import suppress_deprecations
32
32
from reframe .utility import nodelist_abbrev , nodelist_expand , OrderedSet
33
33
from .storage import StorageBackend
34
- from .utility import Aggregator , parse_cmp_spec , parse_query_spec
34
+ from .utility import (Aggregator , parse_cmp_spec ,
35
+ parse_query_spec , parse_time_period )
35
36
36
37
# The schema data version
37
38
# Major version bumps are expected to break the validation of previous schemas
@@ -406,7 +407,7 @@ def create_from_sqlite_db(cls, *dbfiles, exclude_sessions=None,
406
407
407
408
start = time_period .get ('start' , '19700101T0000+0000' )
408
409
end = time_period .get ('end' , 'now' )
409
- ts_start , ts_end = parse_time_period (f'{ start } :{ end } ' )
410
+ qs = parse_query_spec (f'{ start } :{ end } ' )
410
411
include_sessions = set (include_sessions ) if include_sessions else set ()
411
412
exclude_sessions = set (exclude_sessions ) if exclude_sessions else set ()
412
413
reports = []
@@ -420,8 +421,7 @@ def create_from_sqlite_db(cls, *dbfiles, exclude_sessions=None,
420
421
)
421
422
continue
422
423
423
- sessions = src_backend .fetch_sessions_time_period (ts_start , ts_end )
424
- for sess in sessions :
424
+ for sess in src_backend .fetch_sessions (qs ):
425
425
uuid = sess ['session_info' ]['uuid' ]
426
426
if include_sessions and uuid not in include_sessions :
427
427
continue
0 commit comments