Temporal / endpointTemporal endpoint
A durable Activity or Workflow contract, optionally started by a Temporal Schedule.
When to use
Create this endpoint inside a Temporal connector, then select it from an Input or Sink stream.
Behavior
- Activity executes an ordinary ServiceLib graph and may perform normal side effects through its stream pipeline.
- Workflow executes in Temporal deterministic and replay-safe context; side effects must be delegated to Activities.
- The endpoint can be invoked on demand through Input or started by an optional durable Temporal Schedule.
- Activity-only timeout and heartbeat fields are hidden in Workflow mode.
General properties
Endpoint identity
namestringEndpoint name unique in the topology.
RequiredTemporal properties
Temporal endpoint contract
temporalExecutionTypeActivity | WorkflowSelects the execution domain. Activity enters the ordinary ServiceLib runtime graph; Workflow enters the deterministic Temporal Workflow domain.
RequiredDefault:ActivityAllowed: Activity, WorkflowtaskQueuestringTemporal Task Queue used by the Worker.
RequiredDefault:defaultworkflowExecutionTimeoutmillisecondsMaximum Workflow execution duration; zero uses the Temporal SDK default.
Default:0activityStartToCloseTimeoutmillisecondsMaximum duration of one Activity attempt.
Default:30000Minimum: 1Activity onlyactivityHeartbeatTimeoutmillisecondsMaximum interval between Activity heartbeats; zero disables heartbeat timeout.
Default:0Activity onlymaximumAttemptsintegerMaximum Activity attempts including the initial run. The current endpoint contract requires this field.
RequiredDefault:1Minimum: 1Schedule properties
Designer schedule policy
enabledbooleanStarts scheduler integration when true.
Default:truetracingEnabledbooleanCreates tracing for each admitted source event.
Default:falseschedulecron expressionOptional UTC schedule expression. Empty keeps the endpoint on-demand only.
scheduleIdstringStable Temporal Schedule ID.
Required when schedule is non-empty.timezoneUTCPortable runtimes currently require UTC.
Default:UTCoverlapPolicyAllow | SkipBehavior when the previous firing is still running.
Default:SkipAllowed: Allow, SkipmissedRunPolicySkip | FireOnceBehavior after a delayed firing.
Default:FireOnceAllowed: Skip, FireOnceFunction properties
Generated transport handler and code placement
functionNamesymbolGenerated endpoint handler name.
functionPackagestringGenerated handler package.
publicFunctionbooleanPlaces the handler in shared code.
Default:falsefunctionDescriptiontextGenerated documentation comment.
functionInitializerGroupstringDependency-injection initialization group.
functionModuleModuleShared module for the handler.
Visible when publicFunction is true.Configuration example
temporalExecutionType: Activity
taskQueue: orders
activityStartToCloseTimeout: 30000
maximumAttempts: 3
schedule: ""