Graham McIntire
6476bc8045
The Era5FetchWorker now declares an Oban unique constraint on
{lat, lon, valid_time} for any job in available/scheduled/executing/
retryable, so two backfill runs targeting the same contact grid point
can no longer spawn parallel CDS requests for the same hour.
Because Oban OSS insert_all doesn't honor unique, ERA5 jobs are now
routed through Oban.insert/1 from ContactWeatherEnqueueWorker and the
era5_backfill mix task. Other worker types still use insert_all.
|
||
|---|---|---|
| .. | ||
| backfill_enqueue_worker_test.exs | ||
| contact_weather_enqueue_worker_test.exs | ||
| era5_fetch_worker_test.exs | ||
| hrrr_fetch_worker_test.exs | ||
| iemre_fetch_worker_test.exs | ||
| solar_index_worker_test.exs | ||
| terrain_profile_worker_test.exs | ||
| weather_fetch_worker_test.exs | ||