Daily snapshot of the stops registry

etalab · Jan 29, 2025 · 6d43eea · 6d43eea
1 parent 51e89df
commit 6d43eea
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/apps/transport/lib/jobs/stops_registry_snapshot_job.ex b/apps/transport/lib/jobs/stops_registry_snapshot_job.ex
@@ -0,0 +1,15 @@
+defmodule Transport.Jobs.StopsRegistrySnapshotJob do
+  @moduledoc """
+  Job in charge of building a snapshot of the stops registry.
+  """
+
+  use Oban.Worker, unique: [period: {1, :days}], tags: ["registry"], max_attempts: 3
+  require Logger
+
+  @impl Oban.Worker
+  def perform(_job) do
+    file = "#{System.tmp_dir!()}/registre-arrets.csv"
+
+    Transport.Registry.Engine.execute(file)
+  end
+end
diff --git a/config/runtime.exs b/config/runtime.exs
@@ -161,7 +161,8 @@ oban_prod_crontab = [
   {"30 5 * * *", Transport.Jobs.ImportDatasetMonthlyMetricsJob},
   {"45 5 * * *", Transport.Jobs.ImportResourceMonthlyMetricsJob},
   {"0 8 * * *", Transport.Jobs.WarnUserInactivityJob},
-  {"*/5 * * * *", Transport.Jobs.UpdateCounterCacheJob}
+  {"*/5 * * * *", Transport.Jobs.UpdateCounterCacheJob},
+  {"0 4 * * *", Transport.Jobs.StopsRegistrySnapshotJob}
 ]
 
 # Make sure that all modules exist