import type { StepCheckpoint as _memoflow_v1_StepCheckpoint, StepCheckpoint__Output as _memoflow_v1_StepCheckpoint__Output } from '../../memoflow/v1/StepCheckpoint.js'; import type { Signal as _memoflow_v1_Signal, Signal__Output as _memoflow_v1_Signal__Output } from '../../memoflow/v1/Signal.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 WorkflowTask { 'namespace'?: (string); 'workflow_id'?: (string); 'run_id'?: (string); 'workflow_type'?: (string); 'task_queue'?: (string); 'input'?: (Buffer | Uint8Array | string); 'task_token'?: (string); /** * pre-fetched checkpoints */ 'completed_steps'?: (_memoflow_v1_StepCheckpoint)[]; 'pending_signals'?: (_memoflow_v1_Signal)[]; /** * Lazy hydration (P0.4): when false, completed_steps carries metadata only * (step outputs stripped, output_size populated) because the total output * volume exceeded the inline budget — the worker must fetch full outputs * once via the GetCheckpoints RPC before running the workflow. Errors stay * inline either way. Old servers never set this; absent == true. */ 'outputs_inline'?: (boolean); /** * OpenTelemetry (P3.6): W3C trace context (typically a single "traceparent" * key, optionally "tracestate") propagated from the span active when this * task was dispatched — either the StartWorkflow caller's injected context * or the server's own dispatch span when OTel is enabled. Empty/absent when * OTel is off or no context was active. Observability only — never * consulted for step identity or memoization (Design Law 1 unaffected). */ 'trace_context'?: ({ [key: string]: string; }); 'delivery_identity'?: (_memoflow_v1_TaskDeliveryIdentity | null); 'fork_execution_policy'?: (_memoflow_v1_ForkExecutionPolicy | null); } export interface WorkflowTask__Output { 'namespace': (string); 'workflow_id': (string); 'run_id': (string); 'workflow_type': (string); 'task_queue': (string); 'input': (Buffer); 'task_token': (string); /** * pre-fetched checkpoints */ 'completed_steps': (_memoflow_v1_StepCheckpoint__Output)[]; 'pending_signals': (_memoflow_v1_Signal__Output)[]; /** * Lazy hydration (P0.4): when false, completed_steps carries metadata only * (step outputs stripped, output_size populated) because the total output * volume exceeded the inline budget — the worker must fetch full outputs * once via the GetCheckpoints RPC before running the workflow. Errors stay * inline either way. Old servers never set this; absent == true. */ 'outputs_inline': (boolean); /** * OpenTelemetry (P3.6): W3C trace context (typically a single "traceparent" * key, optionally "tracestate") propagated from the span active when this * task was dispatched — either the StartWorkflow caller's injected context * or the server's own dispatch span when OTel is enabled. Empty/absent when * OTel is off or no context was active. Observability only — never * consulted for step identity or memoization (Design Law 1 unaffected). */ 'trace_context': ({ [key: string]: string; }); 'delivery_identity': (_memoflow_v1_TaskDeliveryIdentity__Output | null); 'fork_execution_policy': (_memoflow_v1_ForkExecutionPolicy__Output | null); }