Skip to content

Enable workflows to request a TEE #2004

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
nolag wants to merge 23 commits into
base: main
Choose a base branch
from
Open

Enable workflows to request a TEE #2004

Show file tree
Hide file tree
Changes from 18 commits
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
b5d368d
Add TeeEnabled to template generator, and add a new requirements call…
nolag Apr 8, 2026
660e58a
Add region
nolag Apr 22, 2026
4294618
Requirements selecting runner
nolag Apr 22, 2026
0a4ed20
Merge branch 'main' into rtinianov_teeWorkflows
nolag Apr 23, 2026
a869861
update proto and fix requirement not met test
nolag Apr 24, 2026
16dba12
Update proto, allow individual triggers to choose where to run
nolag Apr 27, 2026
cf01251
Add max time for requirements selection
nolag Apr 27, 2026
b8745af
Use subscription for the trigger requirement
nolag Apr 27, 2026
2b8b244
Main module satisfies requirements
nolag Apr 28, 2026
58ec02d
remove unused hook from module, the selecting one is now responsible …
nolag Apr 29, 2026
937bc20
Hook to ask implementation to determine if it supports regions
nolag Apr 30, 2026
e578b91
Update protos to use full TEE requirement and not use bytes for the e…
nolag Apr 30, 2026
98d72c5
Send full requirements to modules that accept them
nolag Apr 30, 2026
8e8598d
Regions with any is allowed too, and let the TEE say everything it is…
nolag May 1, 2026
f0dfd6b
Update protos for unknown TEE Type
nolag May 4, 2026
b213255
Merge branch 'main' into rtinianov_teeWorkflows
nolag May 12, 2026
3860740
Fix misc tests that were fixed on a different branch, update to use p…
nolag May 20, 2026
179ae0e
Merge branch 'main' into rtinianov_teeWorkflows
nolag May 20, 2026
e612a5e
Remove file left from prior genreation and update to use the one from…
nolag May 20, 2026
7236bc1
Merge branch 'main' into rtinianov_teeWorkflows
nolag May 20, 2026
d826341
AI feedback addressed
nolag May 20, 2026
50c6721
Pin artifacts test build
nolag May 21, 2026
6762215
Merge branch 'main' into rtinianov_teeWorkflows
nolag May 21, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 5 additions & 6 deletions .mockery.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -38,13 +38,12 @@ packages:
github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host:
interfaces:
ModuleV1: {}
ModuleV2: {}
github.com/smartcontractkit/chainlink-common/pkg/workflows/host:
interfaces:
Module: {}
ExecutionHelper:
config:
inpackage: true
filename: "mock_{{.InterfaceName | snakecase}}_test.go"
mockname: "Mock{{.InterfaceName}}"
dir: "{{.InterfaceDir}}"
mockname: "Mock{{.InterfaceName}}"
github.com/smartcontractkit/chainlink-common/pkg/custmsg:
interfaces:
MessageEmitter:
Expand All @@ -64,4 +63,4 @@ packages:
dir: "{{.InterfaceDir}}/limits"
outpkg: limits
interfaces:
Getter:
Getter:
2 changes: 1 addition & 1 deletion go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ require (
github.com/smartcontractkit/chain-selectors v1.0.89
github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20251024234028-0988426d98f4
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260514104516-a827acdffe43
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260520192008-ba2a4dc64333
github.com/smartcontractkit/chainlink-protos/linking-service/go v0.0.0-20251002192024-d2ad9222409b
github.com/smartcontractkit/chainlink-protos/node-platform v0.0.0-20260205130626-db2a2aab956b
github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0
Expand Down
4 changes: 2 additions & 2 deletions go.sum
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion pkg/beholder/chip_ingress_emitter.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ func (c ChipIngressEmitterConfig) New(client chipingress.Client) (Emitter, error

return &ChipIngressEmitter{
client: client,
lggr: lggr,
lggr: lggr,
stopCh: make(services.StopChan),
}, nil
}
Expand Down
2 changes: 1 addition & 1 deletion pkg/beholder/client_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -936,7 +936,7 @@ func TestClient_batchEmitterService(t *testing.T) {
newBatchClient := func(t *testing.T) *beholder.Client {
t.Helper()
client, err := beholder.NewClient(beholder.Config{
OtelExporterGRPCEndpoint: "localhost:4317",
OtelExporterGRPCEndpoint: "localhost:4317",
// Use simple exporter in this lifecycle test to avoid batch flush/shutdown delays.
EmitterBatchProcessor: false,
LogBatchProcessor: false,
Expand Down
8 changes: 4 additions & 4 deletions pkg/beholder/config.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ type Config struct {
EmitterMaxQueueSize int
// EmitterBatchProcessor controls custom-message export mode:
// true = batched async export; false = immediate per-record export.
EmitterBatchProcessor bool
EmitterBatchProcessor bool

// OTel Trace
TraceSampleRatio float64
Expand Down Expand Up @@ -126,7 +126,7 @@ func DefaultConfig() Config {
EmitterExportInterval: 1 * time.Second,
EmitterMaxQueueSize: 2048,
// Keep batched export enabled by default for throughput.
EmitterBatchProcessor: true,
EmitterBatchProcessor: true,
// OTel message log exporter retry config
LogRetryConfig: defaultRetryConfig.Copy(),
// Trace
Expand All @@ -147,8 +147,8 @@ func DefaultConfig() Config {
LogMaxQueueSize: 2048,
LogBatchProcessor: true,
LogStreamingEnabled: true, // Enable logs streaming by default
LogLevel: zapcore.InfoLevel,
LogCompressor: "gzip",
LogLevel: zapcore.InfoLevel,
LogCompressor: "gzip",
// Chip Ingress Batch Emitter
ChipIngressBatchEmitterEnabled: false,
ChipIngressBufferSize: 1000,
Expand Down
2 changes: 1 addition & 1 deletion pkg/beholder/config_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ func ExampleConfig() {
EmitterExportInterval: 1 * time.Second,
EmitterMaxQueueSize: 2048,
// true uses batched async export for custom messages.
EmitterBatchProcessor: true,
EmitterBatchProcessor: true,
// OTel message log exporter retry config
LogRetryConfig: nil,
// Trace
Expand Down
64 changes: 32 additions & 32 deletions pkg/capabilities/errors/error_codes.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -144,44 +144,44 @@ func (e ErrorCode) String() string {
}

var errorCodeToString = map[ErrorCode]string{
Canceled: "Canceled",
Unknown: "Unknown",
InvalidArgument: "InvalidArgument",
DeadlineExceeded: "DeadlineExceeded",
NotFound: "NotFound",
AlreadyExists: "AlreadyExists",
PermissionDenied: "PermissionDenied",
ResourceExhausted: "ResourceExhausted",
FailedPrecondition: "FailedPrecondition",
Aborted: "Aborted",
OutOfRange: "OutOfRange",
Unimplemented: "Unimplemented",
Internal: "Internal",
Unavailable: "Unavailable",
DataLoss: "DataLoss",
Unauthenticated: "Unauthenticated",
Canceled: "Canceled",
Unknown: "Unknown",
InvalidArgument: "InvalidArgument",
DeadlineExceeded: "DeadlineExceeded",
NotFound: "NotFound",
AlreadyExists: "AlreadyExists",
PermissionDenied: "PermissionDenied",
ResourceExhausted: "ResourceExhausted",
FailedPrecondition: "FailedPrecondition",
Aborted: "Aborted",
OutOfRange: "OutOfRange",
Unimplemented: "Unimplemented",
Internal: "Internal",
Unavailable: "Unavailable",
DataLoss: "DataLoss",
Unauthenticated: "Unauthenticated",
ConsensusFailed: "ConsensusFailed",
LimitExceeded: "LimitExceeded",
InsufficientObservations: "InsufficientObservations",
}

var stringToErrorCode = map[string]ErrorCode{
"Canceled": Canceled,
"Unknown": Unknown,
"InvalidArgument": InvalidArgument,
"DeadlineExceeded": DeadlineExceeded,
"NotFound": NotFound,
"AlreadyExists": AlreadyExists,
"PermissionDenied": PermissionDenied,
"ResourceExhausted": ResourceExhausted,
"FailedPrecondition": FailedPrecondition,
"Aborted": Aborted,
"OutOfRange": OutOfRange,
"Unimplemented": Unimplemented,
"Internal": Internal,
"Unavailable": Unavailable,
"DataLoss": DataLoss,
"Unauthenticated": Unauthenticated,
"Canceled": Canceled,
"Unknown": Unknown,
"InvalidArgument": InvalidArgument,
"DeadlineExceeded": DeadlineExceeded,
"NotFound": NotFound,
"AlreadyExists": AlreadyExists,
"PermissionDenied": PermissionDenied,
"ResourceExhausted": ResourceExhausted,
"FailedPrecondition": FailedPrecondition,
"Aborted": Aborted,
"OutOfRange": OutOfRange,
"Unimplemented": Unimplemented,
"Internal": Internal,
"Unavailable": Unavailable,
"DataLoss": DataLoss,
"Unauthenticated": Unauthenticated,
"ConsensusFailed": ConsensusFailed,
"LimitExceeded": LimitExceeded,
"InsufficientObservations": InsufficientObservations,
Expand Down
Loading
Loading