Skip to content

Reapply "action flow" #350

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

Merged
raphael-goetz merged 1 commit into from
Jul 31, 2026
Merged

Reapply "action flow" #350

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
45 changes: 44 additions & 1 deletion proto/aquila/aquila.action.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,21 @@ package aquila;
import "shared.module.proto";
import "shared.execution_result.proto";
import "shared.struct.proto";
import "shared.flow.proto";
import "shared.translation.proto";
import "shared.errors.proto";

message ActionFlow {
int64 flow_id = 1;
int64 project_id = 2;

repeated shared.FlowSetting settings = 3;
shared.Struct input_schema = 4;
shared.Struct output_schema = 5;
string project_slug = 6;

string name = 7;
}

// Event that gets admitted by an action
message ActionEvent {
Expand Down Expand Up @@ -36,13 +51,36 @@ message ActionExecutionRequest {
int64 project_id = 4;
}

message ActionFlowExecutioRequest {
string execution_identifier = 1;
string flow_id = 2;
shared.Value payload = 3;
}

message ActionExecutionResponse {
// Execution identifier of execution
// Execution identifier of execution
string execution_identifier = 1;
// Result of execution
shared.NodeExecutionResult node_result = 2;
}

message ActionFlowExecutionResponse {
// Execution identifier of execution
string execution_identifier = 1;
oneof result {
shared.Value success = 2;
shared.Error failure = 3;
}
}

message ActionFlowUpdate {
oneof data {
ActionFlow updated_flow = 1;
int64 deleted_flow = 2;
}
}

// Messages sent by the Action
message ActionTransferRequest {
oneof data {
// Identification of the action
Expand All @@ -54,15 +92,20 @@ message ActionTransferRequest {
ActionEvent event = 2;
// Result of execution that was triggered by a execution request
ActionExecutionResponse result = 3;
// Result of an flow execution
ActionFlowExecutionResponse flow_execution_response = 4;
}
}

// Messages sent by Aquila
message ActionTransferResponse {
oneof data {
// Execution request
ActionExecutionRequest execution = 1;
// ModuleConfigurations that have been configured by the user
shared.ModuleConfigurations module_configurations = 2;
// An Action Flow update
ActionFlowUpdate flow_update = 3;
}
}

Expand Down
7 changes: 7 additions & 0 deletions proto/shared/shared.flow.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ package shared;

import "shared.struct.proto";
import "shared.data_type.proto";
import "shared.translation.proto";

message ValidationFlow {
// Database ID -> req. for Aquila to identify in FlowStore
Expand All @@ -21,6 +22,12 @@ message ValidationFlow {
string project_slug = 8;
optional string disable_reason = 9;
string signature = 10;

optional string definition_source = 11;
shared.Struct input_schema = 12;
shared.Struct output_schema = 13;

string name = 14;
}

message ExecutionFlow {
Expand Down
4 changes: 0 additions & 4 deletions proto/velorum/velorum.info.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,6 @@ option ruby_package = "Tucana::Velorum";

package velorum;

import "shared.function.proto";
import "shared.data_type.proto";
import "shared.flow.proto";

message ModelsRequest {}

message Model {
Expand Down