import type { RetryPolicy as _memoflow_v1_RetryPolicy, RetryPolicy__Output as _memoflow_v1_RetryPolicy__Output } from '../../memoflow/v1/RetryPolicy.js'; import type { Timestamp as _google_protobuf_Timestamp, Timestamp__Output as _google_protobuf_Timestamp__Output } from '../../google/protobuf/Timestamp.js'; import type { TaskDeliveryIdentity as _memoflow_v1_TaskDeliveryIdentity, TaskDeliveryIdentity__Output as _memoflow_v1_TaskDeliveryIdentity__Output } from '../../memoflow/v1/TaskDeliveryIdentity.js'; import type { ForkExecutionPolicy as _memoflow_v1_ForkExecutionPolicy, ForkExecutionPolicy__Output as _memoflow_v1_ForkExecutionPolicy__Output } from '../../memoflow/v1/ForkExecutionPolicy.js'; export interface ActivityTask { 'task_token'?: (string); 'namespace'?: (string); 'workflow_id'?: (string); 'run_id'?: (string); 'step_seq'?: (number); 'activity_type'?: (string); 'input'?: (Buffer | Uint8Array | string); 'attempt'?: (number); 'retry_policy'?: (_memoflow_v1_RetryPolicy | null); 'deadline'?: (_google_protobuf_Timestamp | null); /** * OpenTelemetry (P3.6): W3C trace context propagated from the span active * at dispatch time (see WorkflowTask.trace_context doc). Empty when OTel * is off. */ 'trace_context'?: ({ [key: string]: string; }); /** * P6.3 transactional step (Postgres tier only): this attempt's * content-addressed step identity (hash(step_kind, step_name)[:16] + ':' + * occurrence_index — Design Law 1), needed so ctx.transaction() can write * a checkpoint indistinguishable from a server-written one. Empty on * checkpoints scheduled before step_key existed (pre-P0.1) — ctx.transaction() * refuses rather than write an identity-less checkpoint in that case. */ 'step_key'?: (string); 'delivery_identity'?: (_memoflow_v1_TaskDeliveryIdentity | null); 'fork_execution_policy'?: (_memoflow_v1_ForkExecutionPolicy | null); } export interface ActivityTask__Output { 'task_token': (string); 'namespace': (string); 'workflow_id': (string); 'run_id': (string); 'step_seq': (number); 'activity_type': (string); 'input': (Buffer); 'attempt': (number); 'retry_policy': (_memoflow_v1_RetryPolicy__Output | null); 'deadline': (_google_protobuf_Timestamp__Output | null); /** * OpenTelemetry (P3.6): W3C trace context propagated from the span active * at dispatch time (see WorkflowTask.trace_context doc). Empty when OTel * is off. */ 'trace_context': ({ [key: string]: string; }); /** * P6.3 transactional step (Postgres tier only): this attempt's * content-addressed step identity (hash(step_kind, step_name)[:16] + ':' + * occurrence_index — Design Law 1), needed so ctx.transaction() can write * a checkpoint indistinguishable from a server-written one. Empty on * checkpoints scheduled before step_key existed (pre-P0.1) — ctx.transaction() * refuses rather than write an identity-less checkpoint in that case. */ 'step_key': (string); 'delivery_identity': (_memoflow_v1_TaskDeliveryIdentity__Output | null); 'fork_execution_policy': (_memoflow_v1_ForkExecutionPolicy__Output | null); }