Hello,
Thank you for the very detailed notebooks – they really help to explore the dataset!
I’m trying to get all sources with 1 detection in a 0.01 degree circle on the sky:
query = """SELECT dias.diaSourceId, dias.diaObjectId, dias.ssObjectId, dias.band, dias.visit,
dias.midpointMjdTai, dias.ra, dias.dec, dias.psfFlux, dias.psfFluxErr, dias.isDipole, diao.nDiaSources
FROM dp1.DiaSource AS dias
JOIN dp1.DiaObject AS diao ON dias.diaObjectId = diao.diaObjectId
WHERE CONTAINS(POINT('ICRS', dias.ra, dias.dec),
CIRCLE('ICRS', {}, {}, 0.01)) = 1
AND diao.nDiaSources = 1
ORDER BY dias.diaSourceId ASC""".format(ra, dec)
job = service.submit_job(query)
job.run()
job.wait(phases=['COMPLETED', 'ERROR'])
print('Job phase is', job.phase)
if job.phase == 'ERROR':
job.raise_if_error()
assert job.phase == 'COMPLETED'
the job crashes after 2m 9.93s with error:
---------------------------------------------------------------------------
DALQueryError Traceback (most recent call last)
Cell In[14], line 15
13 print('Job phase is', job.phase)
14 if job.phase == 'ERROR':
---> 15 job.raise_if_error()
16 assert job.phase == 'COMPLETED'
File /opt/lsst/software/stack/conda/envs/lsst-scipipe-10.0.0/lib/python3.12/site-packages/pyvo/dal/tap.py:1018, in AsyncTAPJob.raise_if_error(self)
1016 msg = self._job.errorsummary.message.content
1017 msg = msg or "<No useful error from server>"
-> 1018 raise DALQueryError("Query Error: " + msg, self.url)
DALQueryError: Query Error: ConnectTimeout
Is that expected? Is my query malformed? Am I doing something wrong?
(For information: Last executed at 2025-07-08 08:27:46 Paris time)
My apologies!