Skip to content
Open
Changes from all commits
Commits
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
52 changes: 46 additions & 6 deletions proto/aquila/aquila.action.proto
Original file line number Diff line number Diff line change
Expand Up @@ -39,18 +39,54 @@ message ActionLogon {
shared.Module module = 1;
}

// Reference to a sub flow whose result is used as a parameter value
message ActionNodeSubFlowValue {
// Execution identifier of the sub flow execution
string execution_identifier = 1;
}

// A single parameter value of a function
message ActionNodeValue {
oneof value {
// A literal, already resolved value
shared.Value literal_value = 1;
// A value that is produced by executing a sub flow
ActionNodeSubFlowValue sub_flow = 2;
}
}

// Request to execute a request a flow
message ActionExecutionRequest {
// Execution identifier of execution
string execution_identifier = 1;
// Function identifier of flow to execute
string function_identifier = 2;
// Parameters (JSON) of flow required to execute
shared.Struct parameters = 3;
// Parameters of functions required to execute
repeated ActionNodeValue parameters = 3;
// Project Id that this function is emitted for
int64 project_id = 4;
}

// Request to execute a sub flow
message ActionSubFlowExecutionRequest {
// Execution identifier of execution
string execution_identifier = 1;
//parameters for the sub flow to inject
repeated shared.Value parameters = 2;
}

// Result of a sub flow execution
message ActionSubFlowExecutionResponse {
// Execution identifier of execution
string execution_identifier = 1;
oneof result {
// Successful result of the sub flow execution
shared.Value success = 2;
// Error that occurred during the sub flow execution
shared.Error failure = 3;
}
}

message ActionFlowExecutioRequest {
string execution_identifier = 1;
string flow_id = 2;
Expand All @@ -67,10 +103,10 @@ message ActionExecutionResponse {
message ActionFlowExecutionResponse {
// Execution identifier of execution
string execution_identifier = 1;
oneof result {
oneof result {
shared.Value success = 2;
shared.Error failure = 3;
}
}
}

message ActionFlowUpdate {
Expand All @@ -92,8 +128,8 @@ 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;
// Request to execute a sub flow
ActionSubFlowExecutionRequest sub_flow_execution = 4;
}
}

Expand All @@ -106,6 +142,10 @@ message ActionTransferResponse {
shared.ModuleConfigurations module_configurations = 2;
// An Action Flow update
ActionFlowUpdate flow_update = 3;
// Result of an flow execution
ActionFlowExecutionResponse flow_execution_response = 4;
// Result of a sub flow execution
ActionSubFlowExecutionResponse sub_flow_execution_response = 5;
}
}

Expand Down