Skip to content

Commit 0eb3429

Browse files
Revert "action flow"
1 parent 5d9235d commit 0eb3429

3 files changed

Lines changed: 5 additions & 51 deletions

File tree

proto/aquila/aquila.action.proto

Lines changed: 1 addition & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -7,21 +7,6 @@ package aquila;
77
import "shared.module.proto";
88
import "shared.execution_result.proto";
99
import "shared.struct.proto";
10-
import "shared.flow.proto";
11-
import "shared.translation.proto";
12-
import "shared.errors.proto";
13-
14-
message ActionFlow {
15-
int64 flow_id = 1;
16-
int64 project_id = 2;
17-
18-
repeated shared.FlowSetting settings = 3;
19-
shared.Struct input_schema = 4;
20-
shared.Struct output_schema = 5;
21-
string project_slug = 6;
22-
23-
string name = 7;
24-
}
2510

2611
// Event that gets admitted by an action
2712
message ActionEvent {
@@ -51,36 +36,13 @@ message ActionExecutionRequest {
5136
int64 project_id = 4;
5237
}
5338

54-
message ActionFlowExecutioRequest {
55-
string execution_identifier = 1;
56-
string flow_id = 2;
57-
shared.Value payload = 3;
58-
}
59-
6039
message ActionExecutionResponse {
61-
// Execution identifier of execution
40+
// Execution identifier of execution
6241
string execution_identifier = 1;
6342
// Result of execution
6443
shared.NodeExecutionResult node_result = 2;
6544
}
6645

67-
message ActionFlowExecutionResponse {
68-
// Execution identifier of execution
69-
string execution_identifier = 1;
70-
oneof result {
71-
shared.Value success = 2;
72-
shared.Error failure = 3;
73-
}
74-
}
75-
76-
message ActionFlowUpdate {
77-
oneof data {
78-
ActionFlow updated_flow = 1;
79-
int64 deleted_flow = 2;
80-
}
81-
}
82-
83-
// Messages sent by the Action
8446
message ActionTransferRequest {
8547
oneof data {
8648
// Identification of the action
@@ -92,20 +54,15 @@ message ActionTransferRequest {
9254
ActionEvent event = 2;
9355
// Result of execution that was triggered by a execution request
9456
ActionExecutionResponse result = 3;
95-
// Result of an flow execution
96-
ActionFlowExecutionResponse flow_execution_response = 4;
9757
}
9858
}
9959

100-
// Messages sent by Aquila
10160
message ActionTransferResponse {
10261
oneof data {
10362
// Execution request
10463
ActionExecutionRequest execution = 1;
10564
// ModuleConfigurations that have been configured by the user
10665
shared.ModuleConfigurations module_configurations = 2;
107-
// An Action Flow update
108-
ActionFlowUpdate flow_update = 3;
10966
}
11067
}
11168

proto/shared/shared.flow.proto

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ package shared;
66

77
import "shared.struct.proto";
88
import "shared.data_type.proto";
9-
import "shared.translation.proto";
109

1110
message ValidationFlow {
1211
// Database ID -> req. for Aquila to identify in FlowStore
@@ -22,12 +21,6 @@ message ValidationFlow {
2221
string project_slug = 8;
2322
optional string disable_reason = 9;
2423
string signature = 10;
25-
26-
optional string definition_source = 11;
27-
shared.Struct input_schema = 12;
28-
shared.Struct output_schema = 13;
29-
30-
string name = 14;
3124
}
3225

3326
message ExecutionFlow {

proto/velorum/velorum.info.proto

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,10 @@ option ruby_package = "Tucana::Velorum";
44

55
package velorum;
66

7+
import "shared.function.proto";
8+
import "shared.data_type.proto";
9+
import "shared.flow.proto";
10+
711
message ModelsRequest {}
812

913
message Model {

0 commit comments

Comments
 (0)