Skip to content

V2 Connector Plugin #6724

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
wants to merge 6 commits into
base: copy-v2-plugins
Choose a base branch
from
Open

V2 Connector Plugin #6724

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
6d83c20
V2 Connector Plugin
pingsutw Nov 10, 2025
8dbbae3
Add mocks
pingsutw Nov 10, 2025
8bf7b64
wip
pingsutw Nov 11, 2025
a21f8f4
wip
pingsutw Nov 11, 2025
56fa5b7
Fix unit tests
pingsutw Nov 11, 2025
c15b5a6
Handle inputs/outputs
pingsutw Nov 11, 2025
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
16 changes: 8 additions & 8 deletions flyteidl2/cacheservice/cacheservice.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,10 @@ syntax = "proto3";

package flyteidl2.cacheservice;

import "flyteidl2/core/literals.proto";
import "flyteidl2/core/types.proto";
import "flyteidl2/core/identifier.proto";
import "flyteidl2/core/interface.proto";
import "flyteidl2/core/literals.proto";
import "flyteidl2/core/types.proto";
import "google/protobuf/duration.proto";
import "google/protobuf/timestamp.proto";

Expand All @@ -16,19 +16,19 @@ option go_package = "github.com/flyteorg/flyte/v2/gen/go/flyteidl2/cacheservice"
*/
service CacheService {
// Retrieves cached data by key.
rpc Get (GetCacheRequest) returns (GetCacheResponse);
rpc Get(GetCacheRequest) returns (GetCacheResponse);

// Stores or updates cached data by key.
rpc Put (PutCacheRequest) returns (PutCacheResponse);
rpc Put(PutCacheRequest) returns (PutCacheResponse);

// Deletes cached data by key.
rpc Delete (DeleteCacheRequest) returns (DeleteCacheResponse);
rpc Delete(DeleteCacheRequest) returns (DeleteCacheResponse);

// Get or extend a reservation for a cache key
rpc GetOrExtendReservation (GetOrExtendReservationRequest) returns (GetOrExtendReservationResponse);
rpc GetOrExtendReservation(GetOrExtendReservationRequest) returns (GetOrExtendReservationResponse);

// Release the reservation for a cache key
rpc ReleaseReservation (ReleaseReservationRequest) returns (ReleaseReservationResponse);
rpc ReleaseReservation(ReleaseReservationRequest) returns (ReleaseReservationResponse);
}

/*
Expand Down Expand Up @@ -146,4 +146,4 @@ message ReleaseReservationRequest {
*/
message ReleaseReservationResponse {
// Empty, success indicated by no errors
}
}
17 changes: 8 additions & 9 deletions flyteidl2/cacheservice/v2/cacheservice.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,31 +2,30 @@ syntax = "proto3";

package flyteidl3.cacheservice.v2;

option go_package = "github.com/flyteorg/flyte/v2/gen/go/flyteidl2/cacheservice/v2";

import "flyteidl2/core/identifier.proto";
import "flyteidl2/cacheservice/cacheservice.proto";
import "buf/validate/validate.proto";
import "flyteidl2/cacheservice/cacheservice.proto";
import "flyteidl2/core/identifier.proto";

option go_package = "github.com/flyteorg/flyte/v2/gen/go/flyteidl2/cacheservice/v2";

/*
* CacheService defines operations for cache management including retrieval, storage, and deletion of cached task/workflow outputs.
*/
service CacheService {
// Retrieves cached data by key.
rpc Get (GetCacheRequest) returns (flyteidl2.cacheservice.GetCacheResponse);
rpc Get(GetCacheRequest) returns (flyteidl2.cacheservice.GetCacheResponse);

// Stores or updates cached data by key.
rpc Put (PutCacheRequest) returns (flyteidl2.cacheservice.PutCacheResponse);
rpc Put(PutCacheRequest) returns (flyteidl2.cacheservice.PutCacheResponse);

// Deletes cached data by key.
rpc Delete (DeleteCacheRequest) returns (flyteidl2.cacheservice.DeleteCacheResponse);
rpc Delete(DeleteCacheRequest) returns (flyteidl2.cacheservice.DeleteCacheResponse);

// Get or extend a reservation for a cache key
rpc GetOrExtendReservation (GetOrExtendReservationRequest) returns (flyteidl2.cacheservice.GetOrExtendReservationResponse);
rpc GetOrExtendReservation(GetOrExtendReservationRequest) returns (flyteidl2.cacheservice.GetOrExtendReservationResponse);

// Release the reservation for a cache key
rpc ReleaseReservation (ReleaseReservationRequest) returns (flyteidl2.cacheservice.ReleaseReservationResponse);
rpc ReleaseReservation(ReleaseReservationRequest) returns (flyteidl2.cacheservice.ReleaseReservationResponse);
}

/*
Expand Down
16 changes: 8 additions & 8 deletions flyteidl2/event/cloudevents.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,15 +2,15 @@ syntax = "proto3";

package flyteidl2.event;

option go_package = "github.com/flyteorg/flyte/v2/gen/go/flyteidl2/event";

import "flyteidl2/event/event.proto";
import "flyteidl2/core/literals.proto";
import "flyteidl2/core/interface.proto";
import "flyteidl2/core/artifact_id.proto";
import "flyteidl2/core/identifier.proto";
import "flyteidl2/core/interface.proto";
import "flyteidl2/core/literals.proto";
import "flyteidl2/event/event.proto";
import "google/protobuf/timestamp.proto";

option go_package = "github.com/flyteorg/flyte/v2/gen/go/flyteidl2/event";

// This is the cloud event parallel to the raw WorkflowExecutionEvent message. It's filled in with additional
// information that downstream consumers may find useful.
message CloudEventWorkflowExecution {
Expand All @@ -30,7 +30,7 @@ message CloudEventWorkflowExecution {
core.Identifier launch_plan_id = 6;

// We can't have the ExecutionMetadata object directly because of import cycle
map<string,string> labels = 7;
map<string, string> labels = 7;
}

message CloudEventNodeExecution {
Expand All @@ -53,13 +53,13 @@ message CloudEventNodeExecution {
core.Identifier launch_plan_id = 6;

// We can't have the ExecutionMetadata object directly because of import cycle
map<string,string> labels = 7;
map<string, string> labels = 7;
}

message CloudEventTaskExecution {
event.TaskExecutionEvent raw_event = 1;
// We can't have the ExecutionMetadata object directly because of import cycle
map<string,string> labels = 2;
map<string, string> labels = 2;
}

// This event is to be sent by Admin after it creates an execution.
Expand Down
Loading