package rerun.redap_tasks.v1alpha1

Get desktop application:
View/edit binary Protocol Buffers messages

`TasksService` is the service for submitting and querying persistent redap tasks.

• rpc SubmitTasks (SubmitTasksRequest, SubmitTasksResponse)

  tasks.proto:11

  Submit new tasks

  message SubmitTasksRequest

  tasks.proto:39

  `SubmitTasksRequest` is the request message for submitting tasks

  • repeated Task tasks = 1

  message SubmitTasksResponse

  tasks.proto:45

  `SubmitTaskResponse` contains, for each submitted task its submission outcome, encoded as a `RecordBatch`

  • optional common.v1alpha1.DataframePart data = 1

• rpc QueryTasks (QueryTasksRequest, QueryTasksResponse)

  tasks.proto:14

  Query the status of submitted tasks

• rpc FetchTaskOutput (FetchTaskOutputRequest, FetchTaskOutputResponse)

  tasks.proto:17

  Fetch the output of a completed task

• rpc QueryTasksOnCompletion (QueryTasksOnCompletionRequest, stream QueryTasksOnCompletionResponse)

  tasks.proto:25

  Query the status of submitted tasks, waiting for their completion. The method returns a stream of QueryResult. Each item in the stream contains the status of a subset of the tasks, as they complete. The server does not guarantee to immediately send one stream item as soon as a task completes, but may decide to arbitrarily aggregate results into larger batches.

`FetchTaskOutputRequest` is the request message for fetching task output

Used as request type in: frontend.v1alpha1.FrontendService.FetchTaskOutput, TasksService.FetchTaskOutput

• optional common.v1alpha1.TaskId id = 1

  Unique identifier for the task

/ `FetchTaskOutputResponse` is the response message for fetching task output

Used as response type in: frontend.v1alpha1.FrontendService.FetchTaskOutput, TasksService.FetchTaskOutput

• optional common.v1alpha1.DataframePart data = 1

  The output of the task, encoded as a record batch

`QueryTasksOnCompletionRequest` is the request message for querying tasks status. This is close-to-a-copy of `QueryTasksRequest`, with the addition of a timeout.

Used as request type in: frontend.v1alpha1.FrontendService.QueryTasksOnCompletion, TasksService.QueryTasksOnCompletion

• repeated common.v1alpha1.TaskId ids = 1

  Empty queries for all tasks if the server allows it.

• optional google.protobuf.Duration timeout = 2

  Time limit for the server to wait for task completion. The actual maximum time may be arbitrarily capped by the server.

`QueryTaskOnCompletionResponse` is the response message for querying tasks status encoded as a record batch. This is a copy of `QueryTasksResponse`.

Used as response type in: frontend.v1alpha1.FrontendService.QueryTasksOnCompletion, TasksService.QueryTasksOnCompletion

• optional common.v1alpha1.DataframePart data = 1

`QueryTasksRequest` is the request message for querying tasks status

Used as request type in: frontend.v1alpha1.FrontendService.QueryTasks, TasksService.QueryTasks

• repeated common.v1alpha1.TaskId ids = 1

  Empty queries for all tasks if the server allows it.

`QueryTasksResponse` is the response message for querying tasks status encoded as a record batch

Used as response type in: frontend.v1alpha1.FrontendService.QueryTasks, TasksService.QueryTasks

• optional common.v1alpha1.DataframePart data = 1

A task is a unit of work that can be submitted to the system

Used in: SubmitTasksRequest

• optional common.v1alpha1.TaskId id = 1

  Unique identifier for the task

• string task_type = 2

  Type of the task

• bytes task_data = 3

  Task-type dependant data necessary to de-serialize the task