All tasks of the job have been completed.

The job is queued and waiting to be run.

At least one task of the job has been started.

Local filesystem.

Google Cloud Storage.

Amazon Web Services S3.

The task has been cancelled due to user request.

The task has been computed and the output is available.

The task has failed.

The task is queued and waiting to be run.

The task is currently running on some task runner.

DiagramService_ServiceDesc is the grpc.ServiceDesc for DiagramService service.

JobService_ServiceDesc is the grpc.ServiceDesc for JobService service.

Enum value maps for JobState.

Enum value maps for JobState.

RecurrentTaskService_ServiceDesc is the grpc.ServiceDesc for RecurrentTaskService service.

Enum value maps for StorageEventType.

Enum value maps for StorageEventType.

Enum value maps for StorageType.

Enum value maps for StorageType.

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service.

Enum value maps for TaskState.

Enum value maps for TaskState.

Enum value maps for WorkflowDiagramTheme.

Enum value maps for WorkflowDiagramTheme.

WorkflowsService_ServiceDesc is the grpc.ServiceDesc for WorkflowsService service.

CancelJobRequest requests a cancel of a job.

CancelJobResponse is the response to a CancelJobRequest.

CloneJobRequest requests a clone of a job.

A cluster is a grouping of tasks that are related.

ComputedTask is a message specifying a task that has been computed by the task runner.

CreateClusterRequest creates a new cluster.

CronTrigger is a trigger that will trigger a task submission on a schedule.

DeleteAutomationRequest requests the deletion of an automation.

DeleteClusterRequest deletes an existing cluster.

DeleteClusterResponse is the response to DeleteClusterRequest.

A rendered diagram.

FilterJobsRequest requests a list of filtered jobs.

GetClusterRequest requests details for a cluster.

GetJobPrototypeRequest requests a clone prototype of a job.

A clone prototype of a job.

GetJobRequest requests details for a job.

An ID interval.

A job is a logical grouping of tasks that are related.

ListClustersRequest lists all clusters.

ListClustersResponse is the response to ListClustersRequest.

ListJobsRequest requests a list of jobs.

A list of jobs.

NextTaskRequest is the request for requesting the next task to run and marking a task as computed.

NextTaskResponse is the response to the NextTask request.

NextTaskToRun is a message specifying the capabilities of the task runner, and therefore the potential tasks that can be run by that task runner.

Pagination information for paginated queries.

RecurrentTask is an actual submitted task that was triggered by a recurrent task prototype.

RecurrentTaskPrototype is a task prototype that can result in many submitted tasks.

RecurrentTasks is a list of recurrent tasks.

Request to render a diagram.

Options for rendering the diagram.

RetryJobRequest requests a retry of a job that has failed.

RetryJobResponse is the response to a RetryJobRequest.

StorageEventTrigger is a trigger that will trigger a task submission when an object matching the glob pattern is created in a storage location.

Storage location is some kind of storage that can contain data files or objects and be used as a trigger source.

Buckets is a list of storage buckets.

SubmitJobRequest submits and schedules a job for execution.

A task is a single unit of work.

TaskFailedRequest is the request for marking a task as failed.

An identifier for a task.

A lease for a task.

TaskLease is a message specifying the new lease expiration time of a task.

A list of tasks.

TaskStateResponse is the response to the TaskFailed request, indicating the current state of the task marked as failed.

TaskSubmission is a message of a task that is just about to be submitted, either by submitting a job or as a subtask.

A summary of a task.

TriggeredCronEvent contains the details of a concrete event that triggered a cron trigger.

TriggeredStorageEvent contains the details of the concrete event that triggered a storage event trigger.

UnimplementedDiagramServiceServer must be embedded to have forward compatible implementations.

UnimplementedJobServiceServer must be embedded to have forward compatible implementations.

UnimplementedRecurrentTaskServiceServer must be embedded to have forward compatible implementations.

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

UnimplementedWorkflowsServiceServer must be embedded to have forward compatible implementations.

Bytes field (in message).

VisualizeJobRequest requests a visualization of a job.

DiagramServiceClient is the client API for DiagramService service.

DiagramServiceServer is the server API for DiagramService service.

JobServiceClient is the client API for JobService service.

JobServiceServer is the server API for JobService service.

RecurrentTaskServiceClient is the client API for RecurrentTaskService service.

RecurrentTaskServiceServer is the server API for RecurrentTaskService service.

TaskServiceClient is the client API for TaskService service.

TaskServiceServer is the server API for TaskService service.

UnsafeDiagramServiceServer may be embedded to opt out of forward compatibility for this service.

UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service.

UnsafeRecurrentTaskServiceServer may be embedded to opt out of forward compatibility for this service.

UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service.

UnsafeWorkflowsServiceServer may be embedded to opt out of forward compatibility for this service.

WorkflowsServiceClient is the client API for WorkflowsService service.

WorkflowsServiceServer is the server API for WorkflowsService service.

The state of a job.

StorageEventType specifies the type of event that triggered the task.

StorageType specifies a kind of storage bucket that we support.

The state of a task.

The theme in which to render a workflow diagram.