Skip to content

in fetch.get_interval, make sure db is closed #286

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
javierggt merged 1 commit into from
Dec 10, 2025
Merged

in fetch.get_interval, make sure db is closed #286

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
35 changes: 17 additions & 18 deletions cheta/fetch.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2019,31 +2019,30 @@ def get_interval(content, tstart, tstop):
def get_interval_from_db(tstart, tstop, server):
import Ska.DBI

db = Ska.DBI.DBI(dbi="sqlite", server=os.path.join(*server))

query_row = db.fetchone(
"SELECT tstart, rowstart FROM archfiles "
"WHERE filetime < ? order by filetime desc",
(tstart,),
)
if not query_row:
with Ska.DBI.DBI(dbi="sqlite", server=os.path.join(*server)) as db:
query_row = db.fetchone(
"SELECT tstart, rowstart FROM archfiles order by filetime asc"
"SELECT tstart, rowstart FROM archfiles "
"WHERE filetime < ? order by filetime desc",
(tstart,),
)
if not query_row:
query_row = db.fetchone(
"SELECT tstart, rowstart FROM archfiles order by filetime asc"
)

rowstart = query_row["rowstart"]
rowstart = query_row["rowstart"]

query_row = db.fetchone(
"SELECT tstop, rowstop FROM archfiles "
"WHERE filetime > ? order by filetime asc",
(tstop,),
)
if not query_row:
query_row = db.fetchone(
"SELECT tstop, rowstop FROM archfiles order by filetime desc"
"SELECT tstop, rowstop FROM archfiles "
"WHERE filetime > ? order by filetime asc",
(tstop,),
)
if not query_row:
query_row = db.fetchone(
"SELECT tstop, rowstop FROM archfiles order by filetime desc"
)

rowstop = query_row["rowstop"]
rowstop = query_row["rowstop"]

return slice(rowstart, rowstop)

Expand Down