feat(github_hooks): add zebra migrations

Author: loadez

github_hooks/db/migrate/20251118091829_add_expires_at_to_jobs.rb

@@ -0,0 +1,5 @@
+class AddExpiresAtToJobs < ActiveRecord::Migration[6.1]
+  def change
+    add_column :jobs, :expires_at, :datetime
+  end
+end

github_hooks/db/migrate/20251119103829_add_expires_created_index_at_jobs_table.rb

@@ -0,0 +1,11 @@
+class AddExpiresCreatedIndexAtJobsTable < ActiveRecord::Migration[6.1]
+  disable_ddl_transaction!
+
+  def change
+    add_index :jobs,
+              %i[expires_at created_at],
+              name: "index_jobs_on_expires_created_not_null",
+              algorithm: :concurrently,
+              where: "expires_at IS NOT NULL"
+  end
+end

github_hooks/db/migrate/20251119104017_add_organization_created_index_at_jobs_table.rb

@@ -0,0 +1,11 @@
+class AddOrganizationCreatedIndexAtJobsTable < ActiveRecord::Migration[6.1]
+  disable_ddl_transaction!
+
+  def change
+    add_index :jobs,
+              %i[organization_id created_at],
+              name: "index_jobs_on_organization_created_expires_is_null",
+              algorithm: :concurrently,
+              where: "expires_at IS NULL"
+  end
+end

zebra/Makefile

@@ -36,6 +36,8 @@ ZEBRA_CALLBACK_TOKEN_KEYS?="testing"
 CONTAINER_ENV_VARS= \
 	-e CI=$(CI) \
 	-e MIX_ENV=$(MIX_ENV) \
+	-e START_JOB_DELETION_POLICY_MARKER=$(START_JOB_DELETION_POLICY_MARKER) \
+	-e START_JOB_DELETION_POLICY_WORKER=$(START_JOB_DELETION_POLICY_WORKER) \
 	-e START_PUBLIC_JOB_API=$(START_PUBLIC_JOB_API) \
 	-e START_INTERNAL_JOB_API=$(START_INTERNAL_JOB_API) \
 	-e START_INTERNAL_TASK_API=$(START_INTERNAL_TASK_API) \

zebra/test/zebra/workers_test.exs

@@ -3,7 +3,6 @@ defmodule Zebra.Workers.Test do
 
   test "no environment variables set => only default workers start" do
     assert Zebra.Workers.active() == [
-             Zebra.Workers.JobDeletionPolicyWorker,
              Zebra.FeatureProviderInvalidatorWorker
            ]
   end
@@ -13,16 +12,21 @@ defmodule Zebra.Workers.Test do
       System.put_env("START_JOB_STOPPER", "true")
       System.put_env("START_TASK_FAIL_FAST_WORKER", "true")
       System.put_env("START_TASK_FINISHER_WORKER", "true")
+      System.put_env("START_JOB_DELETION_POLICY_MARKER", "true")
+      System.put_env("START_JOB_DELETION_POLICY_WORKER", "true")
 
       on_exit(fn ->
         System.put_env("START_JOB_STOPPER", "false")
         System.put_env("START_TASK_FAIL_FAST_WORKER", "false")
         System.put_env("START_TASK_FINISHER_WORKER", "false")
+        System.put_env("START_JOB_DELETION_POLICY_MARKER", "false")
+        System.put_env("START_JOB_DELETION_POLICY_WORKER", "false")
       end)
     end
 
     test "active workers are returned" do
       assert Zebra.Workers.active() == [
+               Zebra.Workers.JobDeletionPolicyMarker,
                Zebra.Workers.JobDeletionPolicyWorker,
                Zebra.Workers.TaskFinisher,
                Zebra.Workers.TaskFailFast,