fix(workflow-engine): mark completed inner-loop iterations visited on resume

docs-internal/engine/napi-bridge.md

@@ -25,7 +25,7 @@ Rules for `rivetkit-typescript/packages/rivetkit-napi/`. The bridge is pure plum
 ## Payload + error conventions
 
 - `#[napi(object)]` bridge payloads stay plain-data only. If TypeScript needs to cancel native work, use primitives or JS-side polling instead of trying to pass a `#[napi]` class instance through an object field.
-- N-API structured errors cross the JS<->Rust boundary by prefix-encoding `{ group, code, message, metadata }` into `napi::Error.reason`, then normalizing that prefix back into a `RivetError` on the other side.
+- N-API structured errors cross the JS<->Rust boundary by prefix-encoding `{ group, code, message, metadata, rayId }` into `napi::Error.reason`, then normalizing that prefix back into a `RivetError` on the other side.
 - N-API bridge debug logs use stable `kind` plus compact payload summaries, never raw buffers or full request bodies.
 
 ## Receive-loop state lifecycle

rivetkit-typescript/packages/effect/src/RivetError.ts

@@ -31,6 +31,9 @@ export class Forbidden extends Schema.TaggedErrorClass<Forbidden>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -63,6 +66,9 @@ export class ActorNotFound extends Schema.TaggedErrorClass<ActorNotFound>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -95,6 +101,9 @@ export class ActorStopping extends Schema.TaggedErrorClass<ActorStopping>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -127,6 +136,9 @@ export class ActorRestarting extends Schema.TaggedErrorClass<ActorRestarting>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -167,6 +179,9 @@ export class ActionNotFound extends Schema.TaggedErrorClass<ActionNotFound>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -197,6 +212,9 @@ export class ActionTimedOut extends Schema.TaggedErrorClass<ActionTimedOut>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -229,6 +247,9 @@ export class ActionAborted extends Schema.TaggedErrorClass<ActionAborted>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -261,6 +282,9 @@ export class ActorOverloaded extends Schema.TaggedErrorClass<ActorOverloaded>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -293,6 +317,9 @@ export class IncomingMessageTooLong extends Schema.TaggedErrorClass<IncomingMess
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -325,6 +352,9 @@ export class OutgoingMessageTooLong extends Schema.TaggedErrorClass<OutgoingMess
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -357,6 +387,9 @@ export class InvalidEncoding extends Schema.TaggedErrorClass<InvalidEncoding>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -389,6 +422,9 @@ export class InvalidRequest extends Schema.TaggedErrorClass<InvalidRequest>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -421,6 +457,9 @@ export class GuardActorReadyTimeout extends Schema.TaggedErrorClass<GuardActorRe
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -453,6 +492,9 @@ export class GuardActorWakeRetriesExceeded extends Schema.TaggedErrorClass<Guard
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -485,6 +527,9 @@ export class GuardActorRunnerFailed extends Schema.TaggedErrorClass<GuardActorRu
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -517,6 +562,9 @@ export class GuardServiceUnavailable extends Schema.TaggedErrorClass<GuardServic
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -549,6 +597,9 @@ export class GuardActorStoppedWhileWaiting extends Schema.TaggedErrorClass<Guard
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -581,6 +632,9 @@ export class GuardTunnelRequestAborted extends Schema.TaggedErrorClass<GuardTunn
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -613,6 +667,9 @@ export class GuardTunnelMessageTimeout extends Schema.TaggedErrorClass<GuardTunn
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -645,6 +702,9 @@ export class GuardTunnelResponseClosed extends Schema.TaggedErrorClass<GuardTunn
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -677,6 +737,9 @@ export class GuardGatewayResponseStartTimeout extends Schema.TaggedErrorClass<Gu
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return true;
 	}
@@ -709,6 +772,9 @@ export class InternalError extends Schema.TaggedErrorClass<InternalError>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -742,6 +808,9 @@ export class ActionErrorDecodeFailed extends Schema.TaggedErrorClass<ActionError
 	get public() {
 		return this.rivetError.public;
 	}
+	get rayId() {
+		return this.rivetError.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -782,6 +851,9 @@ export class UnknownUserError extends Schema.TaggedErrorClass<UnknownUserError>(
 	get public() {
 		return this.cause.public;
 	}
+	get rayId() {
+		return this.cause.rayId;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -829,6 +901,11 @@ export class UnknownError extends Schema.TaggedErrorClass<UnknownError>(
 			? this.cause.public
 			: undefined;
 	}
+	get rayId() {
+		return this.cause instanceof RivetkitErrors.RivetError
+			? this.cause.rayId
+			: undefined;
+	}
 	get isRetryable(): boolean {
 		return false;
 	}
@@ -987,6 +1064,11 @@ export class RivetError extends Schema.TaggedErrorClass<RivetError>(
 		return "public" in this.reason ? this.reason.public : undefined;
 	}
 
+	/** Delegates to the underlying reason's `rayId` if present. */
+	get rayId(): string | undefined {
+		return "rayId" in this.reason ? this.reason.rayId : undefined;
+	}
+
 	/** Delegates to the underlying reason's `isRetryable` getter. */
 	get isRetryable(): boolean {
 		return this.reason.isRetryable;