Skip to content

Commit

Permalink
Mise à jour de la fréquence de déclenchement des alertes de DEP manqu…
Browse files Browse the repository at this point in the history
…ant pour éviter les fausses alertes (#3834)

## Linked issues

- Resolve #3809

----
Analyse : des alertes de DEP manquant peuvent apparaître de façon
transitoire sur un navire ayant émis un DEP en raison de
synchronisations décalées de différentes données.

Situation actuelle sur les flows impliqués dans le calcul du champ
`departure_datetime_utc` de la table `last_positions`, utilisé par
l'alerte de DEP manquant :
- flow `current_segments` : synchronisation à 2, 22, 42 (minutes de
chaque heure : 13:02, 13:22, 13:42, 14:02, 14:22...)
- flow `risk_fators` : synchronisation à 3, 23, 43
- flow `last_positions` : synchronisation chaque minute
- flow `missing_dep_alerts` : déclenchement à 1, 16, 31, 46

--> Ainsi un DEP émis par le navire à 12:45 sera synchronisé dans
`current_segments` qu'à 13:02, puis dans `risk_factors` à 13:03, puis
dans `last_positions` à 13:04. Lors de l'exécution du flow
`missing_dep_alerts` de 13:01, le champ `departure_datetime_utc` de la
table `last_positions` ne contient donc pas encore l'information du DEP
émis à 12:45. Une alerte est émise pour ce navire à 13:01 alors qu'un
DEP a été émis à 12:45.
--> Lors de l'exécution suivante du flow de `missing_dep_alerts` à
13:16, si l'alerte n'a pas été acquittée (ou refusée) entre temps par
les opérateurs, le flow supprime l'alerte qui n'a plus lieu d'être. Mais
de 13:01 à 13:16, l'alerte reste active alors qu'elle ne devrait pas.

Correction : modification de la fréquence de déclenchement de l'alerte
de DEP manquant pour minimiser la probabilité que ceci se produise :
--> déclenchement du flow `missing_dep_alerts` : déclenchement à 5, 25,
45
  • Loading branch information
VincentAntoine authored Nov 15, 2024
2 parents c9c7083 + 3fed830 commit 2988b2c
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion datascience/src/pipeline/flows_config.py
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,10 @@
]
)
logbook.flow.schedule = CronSchedule("0,5,10,15,20,25,30,35,40,45,50,55 * * * *")
missing_dep_alerts.flow.schedule = CronSchedule("1,16,31,46 * * * *")

# For details on missing DEP alerts timing and risks of bad syncing with other data,
# see https://github.com/MTES-MCT/monitorfish/pull/3834#issue-2637538251
missing_dep_alerts.flow.schedule = CronSchedule("5,25,45 * * * *")
missing_far_alerts.flow.schedule = Schedule(
clocks=[
clocks.CronClock(
Expand Down

0 comments on commit 2988b2c

Please sign in to comment.