fix: include webhook_reply and cron_cursor_job_id in version hash

The version hash calculation in WorkflowVersions.generate_hash/1 did not
include the webhook_reply or cron_cursor_job_id trigger fields. This meant
that changes to these fields were not detected by CLI deploy or sandbox
merge, since the hash remained unchanged.

Add both fields to the trigger_keys list used in hash generation, and add
tests verifying that changing either field produces a different hash.

Signed-off-by: Asish Kumar <officialasishkumar@gmail.com>

Author: officialasishkumar

CHANGELOG.md

@@ -21,6 +21,11 @@ and this project adheres to
 
 ### Fixed
 
+- Include `webhook_reply` and `cron_cursor_job_id` in the workflow version hash
+  so that changes to these trigger fields are properly detected by CLI deploy and
+  sandbox merge
+  [#4596](https://github.com/OpenFn/lightning/issues/4596)
+
 ## [2.16.1-pre1] - 2026-04-04
 
 ### Added

lib/lightning/workflow_versions.ex

@@ -246,7 +246,13 @@ defmodule Lightning.WorkflowVersions do
       :body
     ]
 
-    trigger_keys = [:type, :cron_expression, :enabled]
+    trigger_keys = [
+      :type,
+      :cron_expression,
+      :enabled,
+      :webhook_reply,
+      :cron_cursor_job_id
+    ]
 
     edge_keys = [
       :name,

test/lightning/workflow_versions_test.exs

@@ -493,6 +493,57 @@ defmodule Lightning.WorkflowVersionsTest do
       refute hash1 == hash2
     end
 
+    test "hash changes when webhook_reply changes" do
+      workflow = insert(:workflow, name: "Test")
+
+      trigger =
+        insert(:trigger,
+          workflow: workflow,
+          type: :webhook,
+          webhook_reply: :before_start
+        )
+
+      workflow = Repo.preload(workflow, [:triggers, :jobs, :edges])
+      hash1 = WorkflowVersions.generate_hash(workflow)
+
+      trigger
+      |> Ecto.Changeset.change(webhook_reply: :after_completion)
+      |> Repo.update!()
+
+      workflow = Repo.preload(workflow, [:triggers, :jobs, :edges], force: true)
+      hash2 = WorkflowVersions.generate_hash(workflow)
+
+      refute hash1 == hash2
+    end
+
+    test "hash changes when cron_cursor_job_id changes" do
+      workflow = insert(:workflow, name: "Test")
+      job1 = insert(:job, workflow: workflow, name: "Job A")
+      job2 = insert(:job, workflow: workflow, name: "Job B")
+
+      insert(:trigger,
+        workflow: workflow,
+        type: :cron,
+        cron_expression: "0 * * * *",
+        cron_cursor_job: job1
+      )
+
+      workflow = Repo.preload(workflow, [:triggers, :jobs, :edges])
+      hash1 = WorkflowVersions.generate_hash(workflow)
+
+      # Change the cron cursor job
+      [trigger] = workflow.triggers
+
+      trigger
+      |> Ecto.Changeset.change(cron_cursor_job_id: job2.id)
+      |> Repo.update!()
+
+      workflow = Repo.preload(workflow, [:triggers, :jobs, :edges], force: true)
+      hash2 = WorkflowVersions.generate_hash(workflow)
+
+      refute hash1 == hash2
+    end
+
     test "properly orders triggers by type" do
       workflow = insert(:workflow, name: "Test")