fix(project): include trigger reply fields in version hash

Author: officialasishkumar

.changeset/quiet-seals-battle.md

@@ -0,0 +1,6 @@
+---
+'@openfn/project': patch
+'@openfn/cli': patch
+---
+
+Include `webhook_reply` and `cron_cursor_job_id` in workflow version hashes so CLI deploy stays aligned with Lightning.

packages/project/src/util/version.ts

@@ -54,7 +54,13 @@ export const generateHash = (
     'body',
   ].sort();
 
-  const triggerKeys = ['type', 'cron_expression', 'enabled'].sort();
+  const triggerKeys = [
+    'type',
+    'cron_expression',
+    'enabled',
+    'webhook_reply',
+    'cron_cursor_job_id',
+  ].sort();
 
   const edgeKeys = [
     'name', // generated

packages/project/test/util/version-workflow.test.ts

@@ -384,6 +384,51 @@ test('hash a trigger', (t) => {
   t.not(generateHash(webhook), generateHash(cronExpression));
 });
 
+test('hash changes when webhook_reply changes', (t) => {
+  const wf1 = generateWorkflow(
+    `@name wf-1
+    @id workflow-id
+    t(type=webhook)-x(expression=x)
+    `
+  );
+  const wf2 = generateWorkflow(
+    `@name wf-1
+    @id workflow-id
+    t(type=webhook)-x(expression=x)
+    `
+  );
+
+  (wf1.steps[0] as any).openfn.webhook_reply = 'before_start';
+  (wf2.steps[0] as any).openfn.webhook_reply = 'after_completion';
+
+  t.not(generateHash(wf1), generateHash(wf2));
+});
+
+test('hash changes when cron_cursor_job_id changes', (t) => {
+  const wf1 = generateWorkflow(
+    `@name wf-1
+    @id workflow-id
+    t(type=cron,cron_expression="1")-a
+    a-b
+    `
+  );
+  const wf2 = generateWorkflow(
+    `@name wf-1
+    @id workflow-id
+    t(type=cron,cron_expression="1")-a
+    a-b
+    `
+  );
+
+  const [trigger1, jobA1] = wf1.steps as any[];
+  const [trigger2, , jobB2] = wf2.steps as any[];
+
+  trigger1.openfn.cron_cursor_job_id = jobA1.openfn.uuid;
+  trigger2.openfn.cron_cursor_job_id = jobB2.openfn.uuid;
+
+  t.not(generateHash(wf1), generateHash(wf2));
+});
+
 test('hash changes across an edge', (t) => {
   const basicEdge = generateWorkflow(
     `