Move job to Oban

apps/transport/lib/jobs/outdated_data_notification_job.ex

@@ -0,0 +1,9 @@
+defmodule Transport.Jobs.OutdatedDataNotificationJob do
+  use Oban.Worker, max_attempts: 3, tags: ["notifications"]
+
+  @impl Oban.Worker
+
+  def perform(%Oban.Job{id: job_id}) do
+    Transport.DataChecker.outdated_data(job_id)
+  end
+end

apps/transport/lib/transport/data_checker.ex

@@ -106,11 +106,7 @@ defmodule Transport.DataChecker do
     )
   end
 
-  def outdated_data do
-    # Generated as an integer rather than a UUID because `payload.job_id`
-    # for other notifications are %Oban.Job.id (bigint).
-    job_id = Enum.random(1..Integer.pow(2, 63))
-
+  def outdated_data(job_id) do
     for delay <- possible_delays(),
         date = Date.add(Date.utc_today(), delay) do
       {delay, gtfs_datasets_expiring_on(date)}

apps/transport/lib/transport/scheduler.ex

@@ -13,8 +13,6 @@ defmodule Transport.Scheduler do
     [
       # Every day at 4am UTC
       {"0 4 * * *", {Transport.ImportData, :import_validate_all, []}},
-      # Send email for outdated data
-      {"@daily", {Transport.DataChecker, :outdated_data, []}},
       # Set inactive data
       {"@daily", {Transport.DataChecker, :inactive_data, []}},
       # Watch for new comments on datasets

apps/transport/test/transport/data_checker_test.exs

@@ -233,7 +233,7 @@ defmodule Transport.DataCheckerTest do
         dataset_id: dataset.id
       })
 
-      Transport.DataChecker.outdated_data()
+      Transport.DataChecker.outdated_data(42)
 
       # a first mail to our team
 
@@ -271,7 +271,7 @@ defmodule Transport.DataCheckerTest do
     end
 
     test "outdated_data job with nothing to send should not send email" do
-      Transport.DataChecker.outdated_data()
+      Transport.DataChecker.outdated_data(42)
       assert_no_email_sent()
     end
   end

config/runtime.exs

@@ -160,7 +160,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 0 * * *", Transport.Jobs.OutdatedDataNotificationJob}
 ]
 
 # Make sure that all modules exist