Skip to content

Commit 82d06fb

Browse files
committed
fix: #315 avoid request when no vessel_id found (no excursion, no segment)
1 parent bf8ac26 commit 82d06fb

File tree

1 file changed

+11
-9
lines changed

1 file changed

+11
-9
lines changed

backend/bloom/infra/repositories/repository_segment.py

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -292,15 +292,17 @@ def update_last_segments(self, session: Session, vessel_ids: list[int]) -> int:
292292
values(last_vessel_segment=False))
293293
session.execute(upd1)
294294
session.flush()
295-
last_segments = session.execute(text("""SELECT DISTINCT ON (vessel_id) s.id FROM fct_segment s
296-
JOIN fct_excursion e ON e.id = s.excursion_id
297-
WHERE vessel_id in :vessel_ids
298-
ORDER BY vessel_id, timestamp_start DESC"""),
299-
{"vessel_ids": tuple(vessel_ids)}).all()
300-
ids = [r[0] for r in last_segments]
301-
upd2 = update(sql_model.Segment).where(sql_model.Segment.id.in_(ids)).values(
302-
last_vessel_segment=True)
303-
session.execute(upd2)
295+
ids=[]
296+
if(vessel_ids):
297+
last_segments = session.execute(text("""SELECT DISTINCT ON (vessel_id) s.id FROM fct_segment s
298+
JOIN fct_excursion e ON e.id = s.excursion_id
299+
WHERE vessel_id in :vessel_ids
300+
ORDER BY vessel_id, timestamp_start DESC"""),
301+
{"vessel_ids": tuple(vessel_ids)}).all()
302+
ids = [r[0] for r in last_segments]
303+
upd2 = update(sql_model.Segment).where(sql_model.Segment.id.in_(ids)).values(
304+
last_vessel_segment=True)
305+
session.execute(upd2)
304306
return len(ids)
305307

306308
@staticmethod

0 commit comments

Comments
 (0)