Skip to content

Commit 02bda3e

Browse files
authored
re_protos: expose Tasks endpoints via the redap_frontend (#9578)
### Related * Depends on: #9572 * Part of: rerun-io/dataplatform#545 * Proto definition for: rerun-io/dataplatform#574 ### What Expose the Task Service endpoint via the frontend. Signed-off-by: Andrea Reale <[email protected]>
1 parent a2086b1 commit 02bda3e

File tree

3 files changed

+257
-0
lines changed

3 files changed

+257
-0
lines changed

buf.yaml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ lint:
2626
- crates/store/re_protos/proto/rerun/v1alpha1/frontend.proto
2727
- crates/store/re_protos/proto/rerun/v1alpha1/manifest_registry.proto
2828
- crates/store/re_protos/proto/rerun/v1alpha1/catalog.proto
29+
- crates/store/re_protos/proto/rerun/v1alpha1/tasks.proto
2930
enum_zero_value_suffix: _UNSPECIFIED # see <https://buf.build/docs/lint/rules/?h=enum_zero_value#enum_zero_value_suffix>
3031
breaking:
3132
use:

crates/store/re_protos/proto/rerun/v1alpha1/frontend.proto

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ package rerun.frontend.v1alpha1;
55
import "rerun/v1alpha1/catalog.proto";
66
import "rerun/v1alpha1/common.proto";
77
import "rerun/v1alpha1/manifest_registry.proto";
8+
import "rerun/v1alpha1/tasks.proto";
89

910
// TODO(cmc): I've decided to re-use the underlying response types for now, in the name of expediency.
1011
// This is bad in the long term (breaking changes to the internal APIs should not result in breaking
@@ -105,6 +106,16 @@ service FrontendService {
105106

106107
rpc GetTableSchema(GetTableSchemaRequest) returns (GetTableSchemaResponse) {}
107108
rpc ScanTable(ScanTableRequest) returns (stream ScanTableResponse) {}
109+
110+
// --- Tasks service ---
111+
// Query the status of submitted tasks
112+
rpc Query(rerun.redap_tasks.v1alpha1.QueryRequest) returns (rerun.redap_tasks.v1alpha1.QueryResponse) {}
113+
114+
// Fetch the output of a completed task
115+
rpc FetchOutput(rerun.redap_tasks.v1alpha1.FetchOutputRequest) returns (rerun.redap_tasks.v1alpha1.FetchOutputResponse) {}
116+
117+
// Query the status of submitted tasks as soon as they are no longer pending
118+
rpc QueryOnCompletion(rerun.redap_tasks.v1alpha1.QueryOnCompletionRequest) returns (stream rerun.redap_tasks.v1alpha1.QueryOnCompletionResponse) {}
108119
}
109120

110121
// --- Manifest Registry ---

crates/store/re_protos/src/v1alpha1/rerun.frontend.v1alpha1.rs

Lines changed: 245 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)