// Copyright (C) 2026 Yota Hamada
// SPDX-License-Identifier: GPL-3.0-or-later

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        v6.31.1
// source: proto/coordinator/v1/coordinator.proto

//go:build !protoopaque

package coordinatorv1

import (
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	unsafe "unsafe"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

type Operation int32

const (
	Operation_OPERATION_UNSPECIFIED Operation = 0
	Operation_OPERATION_START       Operation = 1 // Start a new DAG run
	Operation_OPERATION_RETRY       Operation = 2 // Retry an existing run
)

// Enum value maps for Operation.
var (
	Operation_name = map[int32]string{
		0: "OPERATION_UNSPECIFIED",
		1: "OPERATION_START",
		2: "OPERATION_RETRY",
	}
	Operation_value = map[string]int32{
		"OPERATION_UNSPECIFIED": 0,
		"OPERATION_START":       1,
		"OPERATION_RETRY":       2,
	}
)

func (x Operation) Enum() *Operation {
	p := new(Operation)
	*p = x
	return p
}

func (x Operation) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (Operation) Descriptor() protoreflect.EnumDescriptor {
	return file_proto_coordinator_v1_coordinator_proto_enumTypes[0].Descriptor()
}

func (Operation) Type() protoreflect.EnumType {
	return &file_proto_coordinator_v1_coordinator_proto_enumTypes[0]
}

func (x Operation) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Health status of a worker based on heartbeat recency.
type WorkerHealthStatus int32

const (
	WorkerHealthStatus_WORKER_HEALTH_STATUS_UNSPECIFIED WorkerHealthStatus = 0
	WorkerHealthStatus_WORKER_HEALTH_STATUS_HEALTHY     WorkerHealthStatus = 1 // Last heartbeat < 5 seconds
	WorkerHealthStatus_WORKER_HEALTH_STATUS_WARNING     WorkerHealthStatus = 2 // Last heartbeat 5-15 seconds
	WorkerHealthStatus_WORKER_HEALTH_STATUS_UNHEALTHY   WorkerHealthStatus = 3 // Last heartbeat > 15 seconds
)

// Enum value maps for WorkerHealthStatus.
var (
	WorkerHealthStatus_name = map[int32]string{
		0: "WORKER_HEALTH_STATUS_UNSPECIFIED",
		1: "WORKER_HEALTH_STATUS_HEALTHY",
		2: "WORKER_HEALTH_STATUS_WARNING",
		3: "WORKER_HEALTH_STATUS_UNHEALTHY",
	}
	WorkerHealthStatus_value = map[string]int32{
		"WORKER_HEALTH_STATUS_UNSPECIFIED": 0,
		"WORKER_HEALTH_STATUS_HEALTHY":     1,
		"WORKER_HEALTH_STATUS_WARNING":     2,
		"WORKER_HEALTH_STATUS_UNHEALTHY":   3,
	}
)

func (x WorkerHealthStatus) Enum() *WorkerHealthStatus {
	p := new(WorkerHealthStatus)
	*p = x
	return p
}

func (x WorkerHealthStatus) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (WorkerHealthStatus) Descriptor() protoreflect.EnumDescriptor {
	return file_proto_coordinator_v1_coordinator_proto_enumTypes[1].Descriptor()
}

func (WorkerHealthStatus) Type() protoreflect.EnumType {
	return &file_proto_coordinator_v1_coordinator_proto_enumTypes[1]
}

func (x WorkerHealthStatus) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Type of log stream.
type LogStreamType int32

const (
	LogStreamType_LOG_STREAM_TYPE_UNSPECIFIED LogStreamType = 0
	LogStreamType_LOG_STREAM_TYPE_STDOUT      LogStreamType = 1
	LogStreamType_LOG_STREAM_TYPE_STDERR      LogStreamType = 2
	LogStreamType_LOG_STREAM_TYPE_SCHEDULER   LogStreamType = 3 // Scheduler/DAG run log
)

// Enum value maps for LogStreamType.
var (
	LogStreamType_name = map[int32]string{
		0: "LOG_STREAM_TYPE_UNSPECIFIED",
		1: "LOG_STREAM_TYPE_STDOUT",
		2: "LOG_STREAM_TYPE_STDERR",
		3: "LOG_STREAM_TYPE_SCHEDULER",
	}
	LogStreamType_value = map[string]int32{
		"LOG_STREAM_TYPE_UNSPECIFIED": 0,
		"LOG_STREAM_TYPE_STDOUT":      1,
		"LOG_STREAM_TYPE_STDERR":      2,
		"LOG_STREAM_TYPE_SCHEDULER":   3,
	}
)

func (x LogStreamType) Enum() *LogStreamType {
	p := new(LogStreamType)
	*p = x
	return p
}

func (x LogStreamType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (LogStreamType) Descriptor() protoreflect.EnumDescriptor {
	return file_proto_coordinator_v1_coordinator_proto_enumTypes[2].Descriptor()
}

func (LogStreamType) Type() protoreflect.EnumType {
	return &file_proto_coordinator_v1_coordinator_proto_enumTypes[2]
}

func (x LogStreamType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Request message for polling a task.
type PollRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId      string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	PollerId      string                 `protobuf:"bytes,2,opt,name=poller_id,json=pollerId,proto3" json:"poller_id,omitempty"`                                                       // Unique ID for this poll request
	Labels        map[string]string      `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Worker labels for task matching
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PollRequest) Reset() {
	*x = PollRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PollRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PollRequest) ProtoMessage() {}

func (x *PollRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *PollRequest) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *PollRequest) GetPollerId() string {
	if x != nil {
		return x.PollerId
	}
	return ""
}

func (x *PollRequest) GetLabels() map[string]string {
	if x != nil {
		return x.Labels
	}
	return nil
}

func (x *PollRequest) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *PollRequest) SetPollerId(v string) {
	x.PollerId = v
}

func (x *PollRequest) SetLabels(v map[string]string) {
	x.Labels = v
}

type PollRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId string
	PollerId string
	Labels   map[string]string
}

func (b0 PollRequest_builder) Build() *PollRequest {
	m0 := &PollRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.PollerId = b.PollerId
	x.Labels = b.Labels
	return m0
}

// Response message for polling a task.
type PollResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Task          *Task                  `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // The task to process.
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PollResponse) Reset() {
	*x = PollResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PollResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PollResponse) ProtoMessage() {}

func (x *PollResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *PollResponse) GetTask() *Task {
	if x != nil {
		return x.Task
	}
	return nil
}

func (x *PollResponse) SetTask(v *Task) {
	x.Task = v
}

func (x *PollResponse) HasTask() bool {
	if x == nil {
		return false
	}
	return x.Task != nil
}

func (x *PollResponse) ClearTask() {
	x.Task = nil
}

type PollResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Task *Task
}

func (b0 PollResponse_builder) Build() *PollResponse {
	m0 := &PollResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Task = b.Task
	return m0
}

// Request message for dispatching a task.
type DispatchRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Task          *Task                  `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DispatchRequest) Reset() {
	*x = DispatchRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DispatchRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DispatchRequest) ProtoMessage() {}

func (x *DispatchRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *DispatchRequest) GetTask() *Task {
	if x != nil {
		return x.Task
	}
	return nil
}

func (x *DispatchRequest) SetTask(v *Task) {
	x.Task = v
}

func (x *DispatchRequest) HasTask() bool {
	if x == nil {
		return false
	}
	return x.Task != nil
}

func (x *DispatchRequest) ClearTask() {
	x.Task = nil
}

type DispatchRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Task *Task
}

func (b0 DispatchRequest_builder) Build() *DispatchRequest {
	m0 := &DispatchRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.Task = b.Task
	return m0
}

// Response message for dispatching a task.
type DispatchResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DispatchResponse) Reset() {
	*x = DispatchResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DispatchResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DispatchResponse) ProtoMessage() {}

func (x *DispatchResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

type DispatchResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

}

func (b0 DispatchResponse_builder) Build() *DispatchResponse {
	m0 := &DispatchResponse{}
	b, x := &b0, m0
	_, _ = b, x
	return m0
}

// Task to process.
type Task struct {
	state            protoimpl.MessageState `protogen:"hybrid.v1"`
	Operation        Operation              `protobuf:"varint,6,opt,name=operation,proto3,enum=coordinator.v1.Operation" json:"operation,omitempty"`
	RootDagRunName   string                 `protobuf:"bytes,1,opt,name=root_dag_run_name,json=rootDagRunName,proto3" json:"root_dag_run_name,omitempty"`
	RootDagRunId     string                 `protobuf:"bytes,2,opt,name=root_dag_run_id,json=rootDagRunId,proto3" json:"root_dag_run_id,omitempty"`
	ParentDagRunName string                 `protobuf:"bytes,3,opt,name=parent_dag_run_name,json=parentDagRunName,proto3" json:"parent_dag_run_name,omitempty"`
	ParentDagRunId   string                 `protobuf:"bytes,4,opt,name=parent_dag_run_id,json=parentDagRunId,proto3" json:"parent_dag_run_id,omitempty"`
	DagRunId         string                 `protobuf:"bytes,5,opt,name=dag_run_id,json=dagRunId,proto3" json:"dag_run_id,omitempty"`
	Target           string                 `protobuf:"bytes,7,opt,name=target,proto3" json:"target,omitempty"`                                                                                                                  // DAG name or path
	Params           string                 `protobuf:"bytes,8,opt,name=params,proto3" json:"params,omitempty"`                                                                                                                  // Optional: parameters
	Step             string                 `protobuf:"bytes,9,opt,name=step,proto3" json:"step,omitempty"`                                                                                                                      // Optional: specific step (for RETRY)
	WorkerSelector   map[string]string      `protobuf:"bytes,10,rep,name=worker_selector,json=workerSelector,proto3" json:"worker_selector,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Required worker labels for execution
	Definition       string                 `protobuf:"bytes,11,opt,name=definition,proto3" json:"definition,omitempty"`                                                                                                         // Optional: DAG definition (YAML) for local DAGs
	WorkerId         string                 `protobuf:"bytes,12,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`                                                                                             // ID of the worker that will execute this task
	// Previous status for OPERATION_RETRY in shared-nothing mode.
	// When set, workers can retry without needing local DAGRunStore access.
	PreviousStatus *DAGRunStatusProto `protobuf:"bytes,13,opt,name=previous_status,json=previousStatus,proto3" json:"previous_status,omitempty"`
	// Attempt ID created by coordinator. Workers use this to create attempts with the same ID.
	AttemptId string `protobuf:"bytes,14,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	// Globally unique attempt identifier for cancellation tracking.
	AttemptKey string `protobuf:"bytes,15,opt,name=attempt_key,json=attemptKey,proto3" json:"attempt_key,omitempty"`
	// Additional labels (comma-separated key=value or key-only) to apply to the DAG run.
	Labels string `protobuf:"bytes,16,opt,name=labels,proto3" json:"labels,omitempty"`
	// Base config YAML content for workers (avoids relying on local base config files).
	BaseConfig string `protobuf:"bytes,17,opt,name=base_config,json=baseConfig,proto3" json:"base_config,omitempty"`
	// RFC 3339 timestamp of when this task was originally scheduled.
	ScheduleTime string `protobuf:"bytes,18,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
	// Enables parent-managed step retries for this task.
	ExternalStepRetry bool `protobuf:"varint,19,opt,name=external_step_retry,json=externalStepRetry,proto3" json:"external_step_retry,omitempty"`
	// Queue/proc-group name used for distributed queue capacity accounting.
	QueueName string `protobuf:"bytes,20,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// Coordinator instance that owns this task after claim.
	OwnerCoordinatorId   string `protobuf:"bytes,21,opt,name=owner_coordinator_id,json=ownerCoordinatorId,proto3" json:"owner_coordinator_id,omitempty"`
	OwnerCoordinatorHost string `protobuf:"bytes,22,opt,name=owner_coordinator_host,json=ownerCoordinatorHost,proto3" json:"owner_coordinator_host,omitempty"`
	OwnerCoordinatorPort int32  `protobuf:"varint,23,opt,name=owner_coordinator_port,json=ownerCoordinatorPort,proto3" json:"owner_coordinator_port,omitempty"`
	// Durable token identifying the shared task claim.
	ClaimToken string `protobuf:"bytes,24,opt,name=claim_token,json=claimToken,proto3" json:"claim_token,omitempty"`
	// Original DAG file path for provenance-aware reschedule-from-file behavior.
	SourceFile string `protobuf:"bytes,25,opt,name=source_file,json=sourceFile,proto3" json:"source_file,omitempty"`
	// Opaque execution-scoped agent settings snapshot for distributed workers.
	AgentSnapshot []byte `protobuf:"bytes,26,opt,name=agent_snapshot,json=agentSnapshot,proto3" json:"agent_snapshot,omitempty"`
	// Content-addressed workspace bundle for action sub-DAGs.
	WorkspaceBundleDigest      string `protobuf:"bytes,27,opt,name=workspace_bundle_digest,json=workspaceBundleDigest,proto3" json:"workspace_bundle_digest,omitempty"`
	WorkspaceBundleSize        int64  `protobuf:"varint,28,opt,name=workspace_bundle_size,json=workspaceBundleSize,proto3" json:"workspace_bundle_size,omitempty"`
	WorkspaceBundleDagPath     string `protobuf:"bytes,29,opt,name=workspace_bundle_dag_path,json=workspaceBundleDagPath,proto3" json:"workspace_bundle_dag_path,omitempty"`
	WorkspaceBundleOriginalRef string `protobuf:"bytes,30,opt,name=workspace_bundle_original_ref,json=workspaceBundleOriginalRef,proto3" json:"workspace_bundle_original_ref,omitempty"`
	WorkspaceBundleResolvedRef string `protobuf:"bytes,31,opt,name=workspace_bundle_resolved_ref,json=workspaceBundleResolvedRef,proto3" json:"workspace_bundle_resolved_ref,omitempty"`
	unknownFields              protoimpl.UnknownFields
	sizeCache                  protoimpl.SizeCache
}

func (x *Task) Reset() {
	*x = Task{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Task) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Task) ProtoMessage() {}

func (x *Task) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *Task) GetOperation() Operation {
	if x != nil {
		return x.Operation
	}
	return Operation_OPERATION_UNSPECIFIED
}

func (x *Task) GetRootDagRunName() string {
	if x != nil {
		return x.RootDagRunName
	}
	return ""
}

func (x *Task) GetRootDagRunId() string {
	if x != nil {
		return x.RootDagRunId
	}
	return ""
}

func (x *Task) GetParentDagRunName() string {
	if x != nil {
		return x.ParentDagRunName
	}
	return ""
}

func (x *Task) GetParentDagRunId() string {
	if x != nil {
		return x.ParentDagRunId
	}
	return ""
}

func (x *Task) GetDagRunId() string {
	if x != nil {
		return x.DagRunId
	}
	return ""
}

func (x *Task) GetTarget() string {
	if x != nil {
		return x.Target
	}
	return ""
}

func (x *Task) GetParams() string {
	if x != nil {
		return x.Params
	}
	return ""
}

func (x *Task) GetStep() string {
	if x != nil {
		return x.Step
	}
	return ""
}

func (x *Task) GetWorkerSelector() map[string]string {
	if x != nil {
		return x.WorkerSelector
	}
	return nil
}

func (x *Task) GetDefinition() string {
	if x != nil {
		return x.Definition
	}
	return ""
}

func (x *Task) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *Task) GetPreviousStatus() *DAGRunStatusProto {
	if x != nil {
		return x.PreviousStatus
	}
	return nil
}

func (x *Task) GetAttemptId() string {
	if x != nil {
		return x.AttemptId
	}
	return ""
}

func (x *Task) GetAttemptKey() string {
	if x != nil {
		return x.AttemptKey
	}
	return ""
}

func (x *Task) GetLabels() string {
	if x != nil {
		return x.Labels
	}
	return ""
}

func (x *Task) GetBaseConfig() string {
	if x != nil {
		return x.BaseConfig
	}
	return ""
}

func (x *Task) GetScheduleTime() string {
	if x != nil {
		return x.ScheduleTime
	}
	return ""
}

func (x *Task) GetExternalStepRetry() bool {
	if x != nil {
		return x.ExternalStepRetry
	}
	return false
}

func (x *Task) GetQueueName() string {
	if x != nil {
		return x.QueueName
	}
	return ""
}

func (x *Task) GetOwnerCoordinatorId() string {
	if x != nil {
		return x.OwnerCoordinatorId
	}
	return ""
}

func (x *Task) GetOwnerCoordinatorHost() string {
	if x != nil {
		return x.OwnerCoordinatorHost
	}
	return ""
}

func (x *Task) GetOwnerCoordinatorPort() int32 {
	if x != nil {
		return x.OwnerCoordinatorPort
	}
	return 0
}

func (x *Task) GetClaimToken() string {
	if x != nil {
		return x.ClaimToken
	}
	return ""
}

func (x *Task) GetSourceFile() string {
	if x != nil {
		return x.SourceFile
	}
	return ""
}

func (x *Task) GetAgentSnapshot() []byte {
	if x != nil {
		return x.AgentSnapshot
	}
	return nil
}

func (x *Task) GetWorkspaceBundleDigest() string {
	if x != nil {
		return x.WorkspaceBundleDigest
	}
	return ""
}

func (x *Task) GetWorkspaceBundleSize() int64 {
	if x != nil {
		return x.WorkspaceBundleSize
	}
	return 0
}

func (x *Task) GetWorkspaceBundleDagPath() string {
	if x != nil {
		return x.WorkspaceBundleDagPath
	}
	return ""
}

func (x *Task) GetWorkspaceBundleOriginalRef() string {
	if x != nil {
		return x.WorkspaceBundleOriginalRef
	}
	return ""
}

func (x *Task) GetWorkspaceBundleResolvedRef() string {
	if x != nil {
		return x.WorkspaceBundleResolvedRef
	}
	return ""
}

func (x *Task) SetOperation(v Operation) {
	x.Operation = v
}

func (x *Task) SetRootDagRunName(v string) {
	x.RootDagRunName = v
}

func (x *Task) SetRootDagRunId(v string) {
	x.RootDagRunId = v
}

func (x *Task) SetParentDagRunName(v string) {
	x.ParentDagRunName = v
}

func (x *Task) SetParentDagRunId(v string) {
	x.ParentDagRunId = v
}

func (x *Task) SetDagRunId(v string) {
	x.DagRunId = v
}

func (x *Task) SetTarget(v string) {
	x.Target = v
}

func (x *Task) SetParams(v string) {
	x.Params = v
}

func (x *Task) SetStep(v string) {
	x.Step = v
}

func (x *Task) SetWorkerSelector(v map[string]string) {
	x.WorkerSelector = v
}

func (x *Task) SetDefinition(v string) {
	x.Definition = v
}

func (x *Task) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *Task) SetPreviousStatus(v *DAGRunStatusProto) {
	x.PreviousStatus = v
}

func (x *Task) SetAttemptId(v string) {
	x.AttemptId = v
}

func (x *Task) SetAttemptKey(v string) {
	x.AttemptKey = v
}

func (x *Task) SetLabels(v string) {
	x.Labels = v
}

func (x *Task) SetBaseConfig(v string) {
	x.BaseConfig = v
}

func (x *Task) SetScheduleTime(v string) {
	x.ScheduleTime = v
}

func (x *Task) SetExternalStepRetry(v bool) {
	x.ExternalStepRetry = v
}

func (x *Task) SetQueueName(v string) {
	x.QueueName = v
}

func (x *Task) SetOwnerCoordinatorId(v string) {
	x.OwnerCoordinatorId = v
}

func (x *Task) SetOwnerCoordinatorHost(v string) {
	x.OwnerCoordinatorHost = v
}

func (x *Task) SetOwnerCoordinatorPort(v int32) {
	x.OwnerCoordinatorPort = v
}

func (x *Task) SetClaimToken(v string) {
	x.ClaimToken = v
}

func (x *Task) SetSourceFile(v string) {
	x.SourceFile = v
}

func (x *Task) SetAgentSnapshot(v []byte) {
	if v == nil {
		v = []byte{}
	}
	x.AgentSnapshot = v
}

func (x *Task) SetWorkspaceBundleDigest(v string) {
	x.WorkspaceBundleDigest = v
}

func (x *Task) SetWorkspaceBundleSize(v int64) {
	x.WorkspaceBundleSize = v
}

func (x *Task) SetWorkspaceBundleDagPath(v string) {
	x.WorkspaceBundleDagPath = v
}

func (x *Task) SetWorkspaceBundleOriginalRef(v string) {
	x.WorkspaceBundleOriginalRef = v
}

func (x *Task) SetWorkspaceBundleResolvedRef(v string) {
	x.WorkspaceBundleResolvedRef = v
}

func (x *Task) HasPreviousStatus() bool {
	if x == nil {
		return false
	}
	return x.PreviousStatus != nil
}

func (x *Task) ClearPreviousStatus() {
	x.PreviousStatus = nil
}

type Task_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Operation        Operation
	RootDagRunName   string
	RootDagRunId     string
	ParentDagRunName string
	ParentDagRunId   string
	DagRunId         string
	Target           string
	Params           string
	Step             string
	WorkerSelector   map[string]string
	Definition       string
	WorkerId         string
	// Previous status for OPERATION_RETRY in shared-nothing mode.
	// When set, workers can retry without needing local DAGRunStore access.
	PreviousStatus *DAGRunStatusProto
	// Attempt ID created by coordinator. Workers use this to create attempts with the same ID.
	AttemptId string
	// Globally unique attempt identifier for cancellation tracking.
	AttemptKey string
	// Additional labels (comma-separated key=value or key-only) to apply to the DAG run.
	Labels string
	// Base config YAML content for workers (avoids relying on local base config files).
	BaseConfig string
	// RFC 3339 timestamp of when this task was originally scheduled.
	ScheduleTime string
	// Enables parent-managed step retries for this task.
	ExternalStepRetry bool
	// Queue/proc-group name used for distributed queue capacity accounting.
	QueueName string
	// Coordinator instance that owns this task after claim.
	OwnerCoordinatorId   string
	OwnerCoordinatorHost string
	OwnerCoordinatorPort int32
	// Durable token identifying the shared task claim.
	ClaimToken string
	// Original DAG file path for provenance-aware reschedule-from-file behavior.
	SourceFile string
	// Opaque execution-scoped agent settings snapshot for distributed workers.
	AgentSnapshot []byte
	// Content-addressed workspace bundle for action sub-DAGs.
	WorkspaceBundleDigest      string
	WorkspaceBundleSize        int64
	WorkspaceBundleDagPath     string
	WorkspaceBundleOriginalRef string
	WorkspaceBundleResolvedRef string
}

func (b0 Task_builder) Build() *Task {
	m0 := &Task{}
	b, x := &b0, m0
	_, _ = b, x
	x.Operation = b.Operation
	x.RootDagRunName = b.RootDagRunName
	x.RootDagRunId = b.RootDagRunId
	x.ParentDagRunName = b.ParentDagRunName
	x.ParentDagRunId = b.ParentDagRunId
	x.DagRunId = b.DagRunId
	x.Target = b.Target
	x.Params = b.Params
	x.Step = b.Step
	x.WorkerSelector = b.WorkerSelector
	x.Definition = b.Definition
	x.WorkerId = b.WorkerId
	x.PreviousStatus = b.PreviousStatus
	x.AttemptId = b.AttemptId
	x.AttemptKey = b.AttemptKey
	x.Labels = b.Labels
	x.BaseConfig = b.BaseConfig
	x.ScheduleTime = b.ScheduleTime
	x.ExternalStepRetry = b.ExternalStepRetry
	x.QueueName = b.QueueName
	x.OwnerCoordinatorId = b.OwnerCoordinatorId
	x.OwnerCoordinatorHost = b.OwnerCoordinatorHost
	x.OwnerCoordinatorPort = b.OwnerCoordinatorPort
	x.ClaimToken = b.ClaimToken
	x.SourceFile = b.SourceFile
	x.AgentSnapshot = b.AgentSnapshot
	x.WorkspaceBundleDigest = b.WorkspaceBundleDigest
	x.WorkspaceBundleSize = b.WorkspaceBundleSize
	x.WorkspaceBundleDagPath = b.WorkspaceBundleDagPath
	x.WorkspaceBundleOriginalRef = b.WorkspaceBundleOriginalRef
	x.WorkspaceBundleResolvedRef = b.WorkspaceBundleResolvedRef
	return m0
}

// Request message for getting workers.
type GetWorkersRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetWorkersRequest) Reset() {
	*x = GetWorkersRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetWorkersRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetWorkersRequest) ProtoMessage() {}

func (x *GetWorkersRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

type GetWorkersRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

}

func (b0 GetWorkersRequest_builder) Build() *GetWorkersRequest {
	m0 := &GetWorkersRequest{}
	b, x := &b0, m0
	_, _ = b, x
	return m0
}

// Response message for getting workers.
type GetWorkersResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Workers       []*WorkerInfo          `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetWorkersResponse) Reset() {
	*x = GetWorkersResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetWorkersResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetWorkersResponse) ProtoMessage() {}

func (x *GetWorkersResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *GetWorkersResponse) GetWorkers() []*WorkerInfo {
	if x != nil {
		return x.Workers
	}
	return nil
}

func (x *GetWorkersResponse) SetWorkers(v []*WorkerInfo) {
	x.Workers = v
}

type GetWorkersResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Workers []*WorkerInfo
}

func (b0 GetWorkersResponse_builder) Build() *GetWorkersResponse {
	m0 := &GetWorkersResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Workers = b.Workers
	return m0
}

// Information about a worker and its pollers.
type WorkerInfo struct {
	state       protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId    string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	PollerId    string                 `protobuf:"bytes,2,opt,name=poller_id,json=pollerId,proto3" json:"poller_id,omitempty"` // Deprecated: Only used for backward compatibility
	Labels      map[string]string      `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	ConnectedAt int64                  `protobuf:"varint,4,opt,name=connected_at,json=connectedAt,proto3" json:"connected_at,omitempty"` // Unix timestamp in seconds
	// Aggregated stats from heartbeat
	TotalPollers    int32              `protobuf:"varint,5,opt,name=total_pollers,json=totalPollers,proto3" json:"total_pollers,omitempty"`
	BusyPollers     int32              `protobuf:"varint,6,opt,name=busy_pollers,json=busyPollers,proto3" json:"busy_pollers,omitempty"`
	RunningTasks    []*RunningTask     `protobuf:"bytes,7,rep,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`
	LastHeartbeatAt int64              `protobuf:"varint,8,opt,name=last_heartbeat_at,json=lastHeartbeatAt,proto3" json:"last_heartbeat_at,omitempty"`                             // Unix timestamp of last heartbeat
	HealthStatus    WorkerHealthStatus `protobuf:"varint,9,opt,name=health_status,json=healthStatus,proto3,enum=coordinator.v1.WorkerHealthStatus" json:"health_status,omitempty"` // Health status based on heartbeat recency
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *WorkerInfo) Reset() {
	*x = WorkerInfo{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *WorkerInfo) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*WorkerInfo) ProtoMessage() {}

func (x *WorkerInfo) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *WorkerInfo) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *WorkerInfo) GetPollerId() string {
	if x != nil {
		return x.PollerId
	}
	return ""
}

func (x *WorkerInfo) GetLabels() map[string]string {
	if x != nil {
		return x.Labels
	}
	return nil
}

func (x *WorkerInfo) GetConnectedAt() int64 {
	if x != nil {
		return x.ConnectedAt
	}
	return 0
}

func (x *WorkerInfo) GetTotalPollers() int32 {
	if x != nil {
		return x.TotalPollers
	}
	return 0
}

func (x *WorkerInfo) GetBusyPollers() int32 {
	if x != nil {
		return x.BusyPollers
	}
	return 0
}

func (x *WorkerInfo) GetRunningTasks() []*RunningTask {
	if x != nil {
		return x.RunningTasks
	}
	return nil
}

func (x *WorkerInfo) GetLastHeartbeatAt() int64 {
	if x != nil {
		return x.LastHeartbeatAt
	}
	return 0
}

func (x *WorkerInfo) GetHealthStatus() WorkerHealthStatus {
	if x != nil {
		return x.HealthStatus
	}
	return WorkerHealthStatus_WORKER_HEALTH_STATUS_UNSPECIFIED
}

func (x *WorkerInfo) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *WorkerInfo) SetPollerId(v string) {
	x.PollerId = v
}

func (x *WorkerInfo) SetLabels(v map[string]string) {
	x.Labels = v
}

func (x *WorkerInfo) SetConnectedAt(v int64) {
	x.ConnectedAt = v
}

func (x *WorkerInfo) SetTotalPollers(v int32) {
	x.TotalPollers = v
}

func (x *WorkerInfo) SetBusyPollers(v int32) {
	x.BusyPollers = v
}

func (x *WorkerInfo) SetRunningTasks(v []*RunningTask) {
	x.RunningTasks = v
}

func (x *WorkerInfo) SetLastHeartbeatAt(v int64) {
	x.LastHeartbeatAt = v
}

func (x *WorkerInfo) SetHealthStatus(v WorkerHealthStatus) {
	x.HealthStatus = v
}

type WorkerInfo_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId    string
	PollerId    string
	Labels      map[string]string
	ConnectedAt int64
	// Aggregated stats from heartbeat
	TotalPollers    int32
	BusyPollers     int32
	RunningTasks    []*RunningTask
	LastHeartbeatAt int64
	HealthStatus    WorkerHealthStatus
}

func (b0 WorkerInfo_builder) Build() *WorkerInfo {
	m0 := &WorkerInfo{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.PollerId = b.PollerId
	x.Labels = b.Labels
	x.ConnectedAt = b.ConnectedAt
	x.TotalPollers = b.TotalPollers
	x.BusyPollers = b.BusyPollers
	x.RunningTasks = b.RunningTasks
	x.LastHeartbeatAt = b.LastHeartbeatAt
	x.HealthStatus = b.HealthStatus
	return m0
}

// Request message for heartbeat.
type HeartbeatRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId      string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Labels        map[string]string      `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	Stats         *WorkerStats           `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HeartbeatRequest) Reset() {
	*x = HeartbeatRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HeartbeatRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HeartbeatRequest) ProtoMessage() {}

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *HeartbeatRequest) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *HeartbeatRequest) GetLabels() map[string]string {
	if x != nil {
		return x.Labels
	}
	return nil
}

func (x *HeartbeatRequest) GetStats() *WorkerStats {
	if x != nil {
		return x.Stats
	}
	return nil
}

func (x *HeartbeatRequest) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *HeartbeatRequest) SetLabels(v map[string]string) {
	x.Labels = v
}

func (x *HeartbeatRequest) SetStats(v *WorkerStats) {
	x.Stats = v
}

func (x *HeartbeatRequest) HasStats() bool {
	if x == nil {
		return false
	}
	return x.Stats != nil
}

func (x *HeartbeatRequest) ClearStats() {
	x.Stats = nil
}

type HeartbeatRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId string
	Labels   map[string]string
	Stats    *WorkerStats
}

func (b0 HeartbeatRequest_builder) Build() *HeartbeatRequest {
	m0 := &HeartbeatRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.Labels = b.Labels
	x.Stats = b.Stats
	return m0
}

// Response message for heartbeat.
type HeartbeatResponse struct {
	state protoimpl.MessageState `protogen:"hybrid.v1"`
	// List of DAG runs that should be cancelled by the worker.
	// Workers check this on each heartbeat and cancel matching running tasks.
	CancelledRuns []*CancelledRun `protobuf:"bytes,1,rep,name=cancelled_runs,json=cancelledRuns,proto3" json:"cancelled_runs,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HeartbeatResponse) Reset() {
	*x = HeartbeatResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HeartbeatResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HeartbeatResponse) ProtoMessage() {}

func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *HeartbeatResponse) GetCancelledRuns() []*CancelledRun {
	if x != nil {
		return x.CancelledRuns
	}
	return nil
}

func (x *HeartbeatResponse) SetCancelledRuns(v []*CancelledRun) {
	x.CancelledRuns = v
}

type HeartbeatResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	// List of DAG runs that should be cancelled by the worker.
	// Workers check this on each heartbeat and cancel matching running tasks.
	CancelledRuns []*CancelledRun
}

func (b0 HeartbeatResponse_builder) Build() *HeartbeatResponse {
	m0 := &HeartbeatResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.CancelledRuns = b.CancelledRuns
	return m0
}

type AckTaskClaimRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId      string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	ClaimToken    string                 `protobuf:"bytes,2,opt,name=claim_token,json=claimToken,proto3" json:"claim_token,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AckTaskClaimRequest) Reset() {
	*x = AckTaskClaimRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AckTaskClaimRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AckTaskClaimRequest) ProtoMessage() {}

func (x *AckTaskClaimRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[10]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *AckTaskClaimRequest) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *AckTaskClaimRequest) GetClaimToken() string {
	if x != nil {
		return x.ClaimToken
	}
	return ""
}

func (x *AckTaskClaimRequest) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *AckTaskClaimRequest) SetClaimToken(v string) {
	x.ClaimToken = v
}

type AckTaskClaimRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId   string
	ClaimToken string
}

func (b0 AckTaskClaimRequest_builder) Build() *AckTaskClaimRequest {
	m0 := &AckTaskClaimRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.ClaimToken = b.ClaimToken
	return m0
}

type AckTaskClaimResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Error         string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AckTaskClaimResponse) Reset() {
	*x = AckTaskClaimResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AckTaskClaimResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AckTaskClaimResponse) ProtoMessage() {}

func (x *AckTaskClaimResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[11]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *AckTaskClaimResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *AckTaskClaimResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *AckTaskClaimResponse) SetAccepted(v bool) {
	x.Accepted = v
}

func (x *AckTaskClaimResponse) SetError(v string) {
	x.Error = v
}

type AckTaskClaimResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Accepted bool
	Error    string
}

func (b0 AckTaskClaimResponse_builder) Build() *AckTaskClaimResponse {
	m0 := &AckTaskClaimResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Accepted = b.Accepted
	x.Error = b.Error
	return m0
}

type RunHeartbeatRequest struct {
	state              protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId           string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	OwnerCoordinatorId string                 `protobuf:"bytes,2,opt,name=owner_coordinator_id,json=ownerCoordinatorId,proto3" json:"owner_coordinator_id,omitempty"`
	RunningTasks       []*RunningTask         `protobuf:"bytes,3,rep,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

func (x *RunHeartbeatRequest) Reset() {
	*x = RunHeartbeatRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunHeartbeatRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunHeartbeatRequest) ProtoMessage() {}

func (x *RunHeartbeatRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[12]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *RunHeartbeatRequest) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *RunHeartbeatRequest) GetOwnerCoordinatorId() string {
	if x != nil {
		return x.OwnerCoordinatorId
	}
	return ""
}

func (x *RunHeartbeatRequest) GetRunningTasks() []*RunningTask {
	if x != nil {
		return x.RunningTasks
	}
	return nil
}

func (x *RunHeartbeatRequest) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *RunHeartbeatRequest) SetOwnerCoordinatorId(v string) {
	x.OwnerCoordinatorId = v
}

func (x *RunHeartbeatRequest) SetRunningTasks(v []*RunningTask) {
	x.RunningTasks = v
}

type RunHeartbeatRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId           string
	OwnerCoordinatorId string
	RunningTasks       []*RunningTask
}

func (b0 RunHeartbeatRequest_builder) Build() *RunHeartbeatRequest {
	m0 := &RunHeartbeatRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.OwnerCoordinatorId = b.OwnerCoordinatorId
	x.RunningTasks = b.RunningTasks
	return m0
}

type RunHeartbeatResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	CancelledRuns []*CancelledRun        `protobuf:"bytes,1,rep,name=cancelled_runs,json=cancelledRuns,proto3" json:"cancelled_runs,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RunHeartbeatResponse) Reset() {
	*x = RunHeartbeatResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunHeartbeatResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunHeartbeatResponse) ProtoMessage() {}

func (x *RunHeartbeatResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[13]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *RunHeartbeatResponse) GetCancelledRuns() []*CancelledRun {
	if x != nil {
		return x.CancelledRuns
	}
	return nil
}

func (x *RunHeartbeatResponse) SetCancelledRuns(v []*CancelledRun) {
	x.CancelledRuns = v
}

type RunHeartbeatResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	CancelledRuns []*CancelledRun
}

func (b0 RunHeartbeatResponse_builder) Build() *RunHeartbeatResponse {
	m0 := &RunHeartbeatResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.CancelledRuns = b.CancelledRuns
	return m0
}

// Information about a cancelled DAG run.
type CancelledRun struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	AttemptKey    string                 `protobuf:"bytes,1,opt,name=attempt_key,json=attemptKey,proto3" json:"attempt_key,omitempty"` // Globally unique attempt identifier to cancel
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CancelledRun) Reset() {
	*x = CancelledRun{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CancelledRun) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CancelledRun) ProtoMessage() {}

func (x *CancelledRun) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[14]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *CancelledRun) GetAttemptKey() string {
	if x != nil {
		return x.AttemptKey
	}
	return ""
}

func (x *CancelledRun) SetAttemptKey(v string) {
	x.AttemptKey = v
}

type CancelledRun_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	AttemptKey string
}

func (b0 CancelledRun_builder) Build() *CancelledRun {
	m0 := &CancelledRun{}
	b, x := &b0, m0
	_, _ = b, x
	x.AttemptKey = b.AttemptKey
	return m0
}

// Worker statistics reported via heartbeat.
type WorkerStats struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	TotalPollers  int32                  `protobuf:"varint,1,opt,name=total_pollers,json=totalPollers,proto3" json:"total_pollers,omitempty"` // Total number of pollers
	BusyPollers   int32                  `protobuf:"varint,2,opt,name=busy_pollers,json=busyPollers,proto3" json:"busy_pollers,omitempty"`    // Number currently processing tasks
	RunningTasks  []*RunningTask         `protobuf:"bytes,3,rep,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`  // Details of running tasks
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *WorkerStats) Reset() {
	*x = WorkerStats{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *WorkerStats) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*WorkerStats) ProtoMessage() {}

func (x *WorkerStats) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[15]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *WorkerStats) GetTotalPollers() int32 {
	if x != nil {
		return x.TotalPollers
	}
	return 0
}

func (x *WorkerStats) GetBusyPollers() int32 {
	if x != nil {
		return x.BusyPollers
	}
	return 0
}

func (x *WorkerStats) GetRunningTasks() []*RunningTask {
	if x != nil {
		return x.RunningTasks
	}
	return nil
}

func (x *WorkerStats) SetTotalPollers(v int32) {
	x.TotalPollers = v
}

func (x *WorkerStats) SetBusyPollers(v int32) {
	x.BusyPollers = v
}

func (x *WorkerStats) SetRunningTasks(v []*RunningTask) {
	x.RunningTasks = v
}

type WorkerStats_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	TotalPollers int32
	BusyPollers  int32
	RunningTasks []*RunningTask
}

func (b0 WorkerStats_builder) Build() *WorkerStats {
	m0 := &WorkerStats{}
	b, x := &b0, m0
	_, _ = b, x
	x.TotalPollers = b.TotalPollers
	x.BusyPollers = b.BusyPollers
	x.RunningTasks = b.RunningTasks
	return m0
}

// Information about a running task.
type RunningTask struct {
	state            protoimpl.MessageState `protogen:"hybrid.v1"`
	DagRunId         string                 `protobuf:"bytes,1,opt,name=dag_run_id,json=dagRunId,proto3" json:"dag_run_id,omitempty"`
	DagName          string                 `protobuf:"bytes,2,opt,name=dag_name,json=dagName,proto3" json:"dag_name,omitempty"`
	StartedAt        int64                  `protobuf:"varint,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` // Unix timestamp in seconds
	RootDagRunName   string                 `protobuf:"bytes,4,opt,name=root_dag_run_name,json=rootDagRunName,proto3" json:"root_dag_run_name,omitempty"`
	RootDagRunId     string                 `protobuf:"bytes,5,opt,name=root_dag_run_id,json=rootDagRunId,proto3" json:"root_dag_run_id,omitempty"`
	ParentDagRunName string                 `protobuf:"bytes,6,opt,name=parent_dag_run_name,json=parentDagRunName,proto3" json:"parent_dag_run_name,omitempty"`
	ParentDagRunId   string                 `protobuf:"bytes,7,opt,name=parent_dag_run_id,json=parentDagRunId,proto3" json:"parent_dag_run_id,omitempty"`
	AttemptKey       string                 `protobuf:"bytes,8,opt,name=attempt_key,json=attemptKey,proto3" json:"attempt_key,omitempty"` // Globally unique attempt identifier
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *RunningTask) Reset() {
	*x = RunningTask{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RunningTask) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RunningTask) ProtoMessage() {}

func (x *RunningTask) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[16]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *RunningTask) GetDagRunId() string {
	if x != nil {
		return x.DagRunId
	}
	return ""
}

func (x *RunningTask) GetDagName() string {
	if x != nil {
		return x.DagName
	}
	return ""
}

func (x *RunningTask) GetStartedAt() int64 {
	if x != nil {
		return x.StartedAt
	}
	return 0
}

func (x *RunningTask) GetRootDagRunName() string {
	if x != nil {
		return x.RootDagRunName
	}
	return ""
}

func (x *RunningTask) GetRootDagRunId() string {
	if x != nil {
		return x.RootDagRunId
	}
	return ""
}

func (x *RunningTask) GetParentDagRunName() string {
	if x != nil {
		return x.ParentDagRunName
	}
	return ""
}

func (x *RunningTask) GetParentDagRunId() string {
	if x != nil {
		return x.ParentDagRunId
	}
	return ""
}

func (x *RunningTask) GetAttemptKey() string {
	if x != nil {
		return x.AttemptKey
	}
	return ""
}

func (x *RunningTask) SetDagRunId(v string) {
	x.DagRunId = v
}

func (x *RunningTask) SetDagName(v string) {
	x.DagName = v
}

func (x *RunningTask) SetStartedAt(v int64) {
	x.StartedAt = v
}

func (x *RunningTask) SetRootDagRunName(v string) {
	x.RootDagRunName = v
}

func (x *RunningTask) SetRootDagRunId(v string) {
	x.RootDagRunId = v
}

func (x *RunningTask) SetParentDagRunName(v string) {
	x.ParentDagRunName = v
}

func (x *RunningTask) SetParentDagRunId(v string) {
	x.ParentDagRunId = v
}

func (x *RunningTask) SetAttemptKey(v string) {
	x.AttemptKey = v
}

type RunningTask_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	DagRunId         string
	DagName          string
	StartedAt        int64
	RootDagRunName   string
	RootDagRunId     string
	ParentDagRunName string
	ParentDagRunId   string
	AttemptKey       string
}

func (b0 RunningTask_builder) Build() *RunningTask {
	m0 := &RunningTask{}
	b, x := &b0, m0
	_, _ = b, x
	x.DagRunId = b.DagRunId
	x.DagName = b.DagName
	x.StartedAt = b.StartedAt
	x.RootDagRunName = b.RootDagRunName
	x.RootDagRunId = b.RootDagRunId
	x.ParentDagRunName = b.ParentDagRunName
	x.ParentDagRunId = b.ParentDagRunId
	x.AttemptKey = b.AttemptKey
	return m0
}

// Request message for reporting DAG run status.
type ReportStatusRequest struct {
	state              protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId           string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Status             *DAGRunStatusProto     `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	OwnerCoordinatorId string                 `protobuf:"bytes,3,opt,name=owner_coordinator_id,json=ownerCoordinatorId,proto3" json:"owner_coordinator_id,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

func (x *ReportStatusRequest) Reset() {
	*x = ReportStatusRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReportStatusRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReportStatusRequest) ProtoMessage() {}

func (x *ReportStatusRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[17]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *ReportStatusRequest) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *ReportStatusRequest) GetStatus() *DAGRunStatusProto {
	if x != nil {
		return x.Status
	}
	return nil
}

func (x *ReportStatusRequest) GetOwnerCoordinatorId() string {
	if x != nil {
		return x.OwnerCoordinatorId
	}
	return ""
}

func (x *ReportStatusRequest) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *ReportStatusRequest) SetStatus(v *DAGRunStatusProto) {
	x.Status = v
}

func (x *ReportStatusRequest) SetOwnerCoordinatorId(v string) {
	x.OwnerCoordinatorId = v
}

func (x *ReportStatusRequest) HasStatus() bool {
	if x == nil {
		return false
	}
	return x.Status != nil
}

func (x *ReportStatusRequest) ClearStatus() {
	x.Status = nil
}

type ReportStatusRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId           string
	Status             *DAGRunStatusProto
	OwnerCoordinatorId string
}

func (b0 ReportStatusRequest_builder) Build() *ReportStatusRequest {
	m0 := &ReportStatusRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.Status = b.Status
	x.OwnerCoordinatorId = b.OwnerCoordinatorId
	return m0
}

// Response message for reporting DAG run status.
type ReportStatusResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Error         string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ReportStatusResponse) Reset() {
	*x = ReportStatusResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReportStatusResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReportStatusResponse) ProtoMessage() {}

func (x *ReportStatusResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[18]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *ReportStatusResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *ReportStatusResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *ReportStatusResponse) SetAccepted(v bool) {
	x.Accepted = v
}

func (x *ReportStatusResponse) SetError(v string) {
	x.Error = v
}

type ReportStatusResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Accepted bool
	Error    string
}

func (b0 ReportStatusResponse_builder) Build() *ReportStatusResponse {
	m0 := &ReportStatusResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Accepted = b.Accepted
	x.Error = b.Error
	return m0
}

// Full DAG run status (JSON-serialized execution.DAGRunStatus).
type DAGRunStatusProto struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	JsonData      string                 `protobuf:"bytes,1,opt,name=json_data,json=jsonData,proto3" json:"json_data,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DAGRunStatusProto) Reset() {
	*x = DAGRunStatusProto{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DAGRunStatusProto) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DAGRunStatusProto) ProtoMessage() {}

func (x *DAGRunStatusProto) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[19]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *DAGRunStatusProto) GetJsonData() string {
	if x != nil {
		return x.JsonData
	}
	return ""
}

func (x *DAGRunStatusProto) SetJsonData(v string) {
	x.JsonData = v
}

type DAGRunStatusProto_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	JsonData string
}

func (b0 DAGRunStatusProto_builder) Build() *DAGRunStatusProto {
	m0 := &DAGRunStatusProto{}
	b, x := &b0, m0
	_, _ = b, x
	x.JsonData = b.JsonData
	return m0
}

// Log chunk sent from worker to coordinator.
type LogChunk struct {
	state      protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId   string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	DagRunId   string                 `protobuf:"bytes,2,opt,name=dag_run_id,json=dagRunId,proto3" json:"dag_run_id,omitempty"`
	DagName    string                 `protobuf:"bytes,3,opt,name=dag_name,json=dagName,proto3" json:"dag_name,omitempty"`
	StepName   string                 `protobuf:"bytes,4,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
	StreamType LogStreamType          `protobuf:"varint,5,opt,name=stream_type,json=streamType,proto3,enum=coordinator.v1.LogStreamType" json:"stream_type,omitempty"`
	Data       []byte                 `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	Sequence   uint64                 `protobuf:"varint,7,opt,name=sequence,proto3" json:"sequence,omitempty"`              // For ordering
	IsFinal    bool                   `protobuf:"varint,8,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"` // Last chunk for this step
	// Root DAG info for sub-DAGs
	RootDagRunName string `protobuf:"bytes,9,opt,name=root_dag_run_name,json=rootDagRunName,proto3" json:"root_dag_run_name,omitempty"`
	RootDagRunId   string `protobuf:"bytes,10,opt,name=root_dag_run_id,json=rootDagRunId,proto3" json:"root_dag_run_id,omitempty"`
	// Attempt ID for the DAG run
	AttemptId string `protobuf:"bytes,11,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	// Owner coordinator used to validate owner-bound log writes.
	OwnerCoordinatorId string `protobuf:"bytes,12,opt,name=owner_coordinator_id,json=ownerCoordinatorId,proto3" json:"owner_coordinator_id,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

func (x *LogChunk) Reset() {
	*x = LogChunk{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *LogChunk) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*LogChunk) ProtoMessage() {}

func (x *LogChunk) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[20]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *LogChunk) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *LogChunk) GetDagRunId() string {
	if x != nil {
		return x.DagRunId
	}
	return ""
}

func (x *LogChunk) GetDagName() string {
	if x != nil {
		return x.DagName
	}
	return ""
}

func (x *LogChunk) GetStepName() string {
	if x != nil {
		return x.StepName
	}
	return ""
}

func (x *LogChunk) GetStreamType() LogStreamType {
	if x != nil {
		return x.StreamType
	}
	return LogStreamType_LOG_STREAM_TYPE_UNSPECIFIED
}

func (x *LogChunk) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}

func (x *LogChunk) GetSequence() uint64 {
	if x != nil {
		return x.Sequence
	}
	return 0
}

func (x *LogChunk) GetIsFinal() bool {
	if x != nil {
		return x.IsFinal
	}
	return false
}

func (x *LogChunk) GetRootDagRunName() string {
	if x != nil {
		return x.RootDagRunName
	}
	return ""
}

func (x *LogChunk) GetRootDagRunId() string {
	if x != nil {
		return x.RootDagRunId
	}
	return ""
}

func (x *LogChunk) GetAttemptId() string {
	if x != nil {
		return x.AttemptId
	}
	return ""
}

func (x *LogChunk) GetOwnerCoordinatorId() string {
	if x != nil {
		return x.OwnerCoordinatorId
	}
	return ""
}

func (x *LogChunk) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *LogChunk) SetDagRunId(v string) {
	x.DagRunId = v
}

func (x *LogChunk) SetDagName(v string) {
	x.DagName = v
}

func (x *LogChunk) SetStepName(v string) {
	x.StepName = v
}

func (x *LogChunk) SetStreamType(v LogStreamType) {
	x.StreamType = v
}

func (x *LogChunk) SetData(v []byte) {
	if v == nil {
		v = []byte{}
	}
	x.Data = v
}

func (x *LogChunk) SetSequence(v uint64) {
	x.Sequence = v
}

func (x *LogChunk) SetIsFinal(v bool) {
	x.IsFinal = v
}

func (x *LogChunk) SetRootDagRunName(v string) {
	x.RootDagRunName = v
}

func (x *LogChunk) SetRootDagRunId(v string) {
	x.RootDagRunId = v
}

func (x *LogChunk) SetAttemptId(v string) {
	x.AttemptId = v
}

func (x *LogChunk) SetOwnerCoordinatorId(v string) {
	x.OwnerCoordinatorId = v
}

type LogChunk_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId   string
	DagRunId   string
	DagName    string
	StepName   string
	StreamType LogStreamType
	Data       []byte
	Sequence   uint64
	IsFinal    bool
	// Root DAG info for sub-DAGs
	RootDagRunName string
	RootDagRunId   string
	// Attempt ID for the DAG run
	AttemptId string
	// Owner coordinator used to validate owner-bound log writes.
	OwnerCoordinatorId string
}

func (b0 LogChunk_builder) Build() *LogChunk {
	m0 := &LogChunk{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.DagRunId = b.DagRunId
	x.DagName = b.DagName
	x.StepName = b.StepName
	x.StreamType = b.StreamType
	x.Data = b.Data
	x.Sequence = b.Sequence
	x.IsFinal = b.IsFinal
	x.RootDagRunName = b.RootDagRunName
	x.RootDagRunId = b.RootDagRunId
	x.AttemptId = b.AttemptId
	x.OwnerCoordinatorId = b.OwnerCoordinatorId
	return m0
}

// Response message for log streaming.
type StreamLogsResponse struct {
	state          protoimpl.MessageState `protogen:"hybrid.v1"`
	ChunksReceived uint64                 `protobuf:"varint,1,opt,name=chunks_received,json=chunksReceived,proto3" json:"chunks_received,omitempty"`
	BytesWritten   uint64                 `protobuf:"varint,2,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	Error          string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *StreamLogsResponse) Reset() {
	*x = StreamLogsResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StreamLogsResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StreamLogsResponse) ProtoMessage() {}

func (x *StreamLogsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[21]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *StreamLogsResponse) GetChunksReceived() uint64 {
	if x != nil {
		return x.ChunksReceived
	}
	return 0
}

func (x *StreamLogsResponse) GetBytesWritten() uint64 {
	if x != nil {
		return x.BytesWritten
	}
	return 0
}

func (x *StreamLogsResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *StreamLogsResponse) SetChunksReceived(v uint64) {
	x.ChunksReceived = v
}

func (x *StreamLogsResponse) SetBytesWritten(v uint64) {
	x.BytesWritten = v
}

func (x *StreamLogsResponse) SetError(v string) {
	x.Error = v
}

type StreamLogsResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	ChunksReceived uint64
	BytesWritten   uint64
	Error          string
}

func (b0 StreamLogsResponse_builder) Build() *StreamLogsResponse {
	m0 := &StreamLogsResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.ChunksReceived = b.ChunksReceived
	x.BytesWritten = b.BytesWritten
	x.Error = b.Error
	return m0
}

// Artifact chunk sent from worker to coordinator.
type ArtifactChunk struct {
	state        protoimpl.MessageState `protogen:"hybrid.v1"`
	WorkerId     string                 `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	DagRunId     string                 `protobuf:"bytes,2,opt,name=dag_run_id,json=dagRunId,proto3" json:"dag_run_id,omitempty"`
	DagName      string                 `protobuf:"bytes,3,opt,name=dag_name,json=dagName,proto3" json:"dag_name,omitempty"`
	RelativePath string                 `protobuf:"bytes,4,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`
	Data         []byte                 `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Sequence     uint64                 `protobuf:"varint,6,opt,name=sequence,proto3" json:"sequence,omitempty"`
	IsFinal      bool                   `protobuf:"varint,7,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`
	// Root DAG info for sub-DAGs
	RootDagRunName string `protobuf:"bytes,8,opt,name=root_dag_run_name,json=rootDagRunName,proto3" json:"root_dag_run_name,omitempty"`
	RootDagRunId   string `protobuf:"bytes,9,opt,name=root_dag_run_id,json=rootDagRunId,proto3" json:"root_dag_run_id,omitempty"`
	// Attempt ID for the DAG run
	AttemptId string `protobuf:"bytes,10,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	// Owner coordinator used to validate owner-bound artifact writes.
	OwnerCoordinatorId string `protobuf:"bytes,11,opt,name=owner_coordinator_id,json=ownerCoordinatorId,proto3" json:"owner_coordinator_id,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

func (x *ArtifactChunk) Reset() {
	*x = ArtifactChunk{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ArtifactChunk) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ArtifactChunk) ProtoMessage() {}

func (x *ArtifactChunk) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[22]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *ArtifactChunk) GetWorkerId() string {
	if x != nil {
		return x.WorkerId
	}
	return ""
}

func (x *ArtifactChunk) GetDagRunId() string {
	if x != nil {
		return x.DagRunId
	}
	return ""
}

func (x *ArtifactChunk) GetDagName() string {
	if x != nil {
		return x.DagName
	}
	return ""
}

func (x *ArtifactChunk) GetRelativePath() string {
	if x != nil {
		return x.RelativePath
	}
	return ""
}

func (x *ArtifactChunk) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}

func (x *ArtifactChunk) GetSequence() uint64 {
	if x != nil {
		return x.Sequence
	}
	return 0
}

func (x *ArtifactChunk) GetIsFinal() bool {
	if x != nil {
		return x.IsFinal
	}
	return false
}

func (x *ArtifactChunk) GetRootDagRunName() string {
	if x != nil {
		return x.RootDagRunName
	}
	return ""
}

func (x *ArtifactChunk) GetRootDagRunId() string {
	if x != nil {
		return x.RootDagRunId
	}
	return ""
}

func (x *ArtifactChunk) GetAttemptId() string {
	if x != nil {
		return x.AttemptId
	}
	return ""
}

func (x *ArtifactChunk) GetOwnerCoordinatorId() string {
	if x != nil {
		return x.OwnerCoordinatorId
	}
	return ""
}

func (x *ArtifactChunk) SetWorkerId(v string) {
	x.WorkerId = v
}

func (x *ArtifactChunk) SetDagRunId(v string) {
	x.DagRunId = v
}

func (x *ArtifactChunk) SetDagName(v string) {
	x.DagName = v
}

func (x *ArtifactChunk) SetRelativePath(v string) {
	x.RelativePath = v
}

func (x *ArtifactChunk) SetData(v []byte) {
	if v == nil {
		v = []byte{}
	}
	x.Data = v
}

func (x *ArtifactChunk) SetSequence(v uint64) {
	x.Sequence = v
}

func (x *ArtifactChunk) SetIsFinal(v bool) {
	x.IsFinal = v
}

func (x *ArtifactChunk) SetRootDagRunName(v string) {
	x.RootDagRunName = v
}

func (x *ArtifactChunk) SetRootDagRunId(v string) {
	x.RootDagRunId = v
}

func (x *ArtifactChunk) SetAttemptId(v string) {
	x.AttemptId = v
}

func (x *ArtifactChunk) SetOwnerCoordinatorId(v string) {
	x.OwnerCoordinatorId = v
}

type ArtifactChunk_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	WorkerId     string
	DagRunId     string
	DagName      string
	RelativePath string
	Data         []byte
	Sequence     uint64
	IsFinal      bool
	// Root DAG info for sub-DAGs
	RootDagRunName string
	RootDagRunId   string
	// Attempt ID for the DAG run
	AttemptId string
	// Owner coordinator used to validate owner-bound artifact writes.
	OwnerCoordinatorId string
}

func (b0 ArtifactChunk_builder) Build() *ArtifactChunk {
	m0 := &ArtifactChunk{}
	b, x := &b0, m0
	_, _ = b, x
	x.WorkerId = b.WorkerId
	x.DagRunId = b.DagRunId
	x.DagName = b.DagName
	x.RelativePath = b.RelativePath
	x.Data = b.Data
	x.Sequence = b.Sequence
	x.IsFinal = b.IsFinal
	x.RootDagRunName = b.RootDagRunName
	x.RootDagRunId = b.RootDagRunId
	x.AttemptId = b.AttemptId
	x.OwnerCoordinatorId = b.OwnerCoordinatorId
	return m0
}

// Response message for artifact streaming.
type StreamArtifactsResponse struct {
	state          protoimpl.MessageState `protogen:"hybrid.v1"`
	ChunksReceived uint64                 `protobuf:"varint,1,opt,name=chunks_received,json=chunksReceived,proto3" json:"chunks_received,omitempty"`
	BytesWritten   uint64                 `protobuf:"varint,2,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	Error          string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *StreamArtifactsResponse) Reset() {
	*x = StreamArtifactsResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StreamArtifactsResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StreamArtifactsResponse) ProtoMessage() {}

func (x *StreamArtifactsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[23]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *StreamArtifactsResponse) GetChunksReceived() uint64 {
	if x != nil {
		return x.ChunksReceived
	}
	return 0
}

func (x *StreamArtifactsResponse) GetBytesWritten() uint64 {
	if x != nil {
		return x.BytesWritten
	}
	return 0
}

func (x *StreamArtifactsResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *StreamArtifactsResponse) SetChunksReceived(v uint64) {
	x.ChunksReceived = v
}

func (x *StreamArtifactsResponse) SetBytesWritten(v uint64) {
	x.BytesWritten = v
}

func (x *StreamArtifactsResponse) SetError(v string) {
	x.Error = v
}

type StreamArtifactsResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	ChunksReceived uint64
	BytesWritten   uint64
	Error          string
}

func (b0 StreamArtifactsResponse_builder) Build() *StreamArtifactsResponse {
	m0 := &StreamArtifactsResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.ChunksReceived = b.ChunksReceived
	x.BytesWritten = b.BytesWritten
	x.Error = b.Error
	return m0
}

// Workspace bundle descriptor.
type WorkspaceBundle struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Digest        string                 `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	Size          int64                  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	DagPath       string                 `protobuf:"bytes,3,opt,name=dag_path,json=dagPath,proto3" json:"dag_path,omitempty"`
	OriginalRef   string                 `protobuf:"bytes,4,opt,name=original_ref,json=originalRef,proto3" json:"original_ref,omitempty"`
	ResolvedRef   string                 `protobuf:"bytes,5,opt,name=resolved_ref,json=resolvedRef,proto3" json:"resolved_ref,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *WorkspaceBundle) Reset() {
	*x = WorkspaceBundle{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[24]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *WorkspaceBundle) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*WorkspaceBundle) ProtoMessage() {}

func (x *WorkspaceBundle) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[24]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *WorkspaceBundle) GetDigest() string {
	if x != nil {
		return x.Digest
	}
	return ""
}

func (x *WorkspaceBundle) GetSize() int64 {
	if x != nil {
		return x.Size
	}
	return 0
}

func (x *WorkspaceBundle) GetDagPath() string {
	if x != nil {
		return x.DagPath
	}
	return ""
}

func (x *WorkspaceBundle) GetOriginalRef() string {
	if x != nil {
		return x.OriginalRef
	}
	return ""
}

func (x *WorkspaceBundle) GetResolvedRef() string {
	if x != nil {
		return x.ResolvedRef
	}
	return ""
}

func (x *WorkspaceBundle) SetDigest(v string) {
	x.Digest = v
}

func (x *WorkspaceBundle) SetSize(v int64) {
	x.Size = v
}

func (x *WorkspaceBundle) SetDagPath(v string) {
	x.DagPath = v
}

func (x *WorkspaceBundle) SetOriginalRef(v string) {
	x.OriginalRef = v
}

func (x *WorkspaceBundle) SetResolvedRef(v string) {
	x.ResolvedRef = v
}

type WorkspaceBundle_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Digest      string
	Size        int64
	DagPath     string
	OriginalRef string
	ResolvedRef string
}

func (b0 WorkspaceBundle_builder) Build() *WorkspaceBundle {
	m0 := &WorkspaceBundle{}
	b, x := &b0, m0
	_, _ = b, x
	x.Digest = b.Digest
	x.Size = b.Size
	x.DagPath = b.DagPath
	x.OriginalRef = b.OriginalRef
	x.ResolvedRef = b.ResolvedRef
	return m0
}

// Workspace bundle chunk for upload and download streams.
type WorkspaceBundleChunk struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Bundle        *WorkspaceBundle       `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Data          []byte                 `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Sequence      uint64                 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	IsFinal       bool                   `protobuf:"varint,4,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *WorkspaceBundleChunk) Reset() {
	*x = WorkspaceBundleChunk{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[25]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *WorkspaceBundleChunk) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*WorkspaceBundleChunk) ProtoMessage() {}

func (x *WorkspaceBundleChunk) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[25]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *WorkspaceBundleChunk) GetBundle() *WorkspaceBundle {
	if x != nil {
		return x.Bundle
	}
	return nil
}

func (x *WorkspaceBundleChunk) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}

func (x *WorkspaceBundleChunk) GetSequence() uint64 {
	if x != nil {
		return x.Sequence
	}
	return 0
}

func (x *WorkspaceBundleChunk) GetIsFinal() bool {
	if x != nil {
		return x.IsFinal
	}
	return false
}

func (x *WorkspaceBundleChunk) SetBundle(v *WorkspaceBundle) {
	x.Bundle = v
}

func (x *WorkspaceBundleChunk) SetData(v []byte) {
	if v == nil {
		v = []byte{}
	}
	x.Data = v
}

func (x *WorkspaceBundleChunk) SetSequence(v uint64) {
	x.Sequence = v
}

func (x *WorkspaceBundleChunk) SetIsFinal(v bool) {
	x.IsFinal = v
}

func (x *WorkspaceBundleChunk) HasBundle() bool {
	if x == nil {
		return false
	}
	return x.Bundle != nil
}

func (x *WorkspaceBundleChunk) ClearBundle() {
	x.Bundle = nil
}

type WorkspaceBundleChunk_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Bundle   *WorkspaceBundle
	Data     []byte
	Sequence uint64
	IsFinal  bool
}

func (b0 WorkspaceBundleChunk_builder) Build() *WorkspaceBundleChunk {
	m0 := &WorkspaceBundleChunk{}
	b, x := &b0, m0
	_, _ = b, x
	x.Bundle = b.Bundle
	x.Data = b.Data
	x.Sequence = b.Sequence
	x.IsFinal = b.IsFinal
	return m0
}

// Response message for workspace bundle upload.
type PutWorkspaceBundleResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Error         string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PutWorkspaceBundleResponse) Reset() {
	*x = PutWorkspaceBundleResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[26]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PutWorkspaceBundleResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PutWorkspaceBundleResponse) ProtoMessage() {}

func (x *PutWorkspaceBundleResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[26]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *PutWorkspaceBundleResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *PutWorkspaceBundleResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *PutWorkspaceBundleResponse) SetAccepted(v bool) {
	x.Accepted = v
}

func (x *PutWorkspaceBundleResponse) SetError(v string) {
	x.Error = v
}

type PutWorkspaceBundleResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Accepted bool
	Error    string
}

func (b0 PutWorkspaceBundleResponse_builder) Build() *PutWorkspaceBundleResponse {
	m0 := &PutWorkspaceBundleResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Accepted = b.Accepted
	x.Error = b.Error
	return m0
}

// Request message for checking workspace bundle presence.
type HasWorkspaceBundleRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Digest        string                 `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HasWorkspaceBundleRequest) Reset() {
	*x = HasWorkspaceBundleRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[27]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HasWorkspaceBundleRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HasWorkspaceBundleRequest) ProtoMessage() {}

func (x *HasWorkspaceBundleRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[27]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *HasWorkspaceBundleRequest) GetDigest() string {
	if x != nil {
		return x.Digest
	}
	return ""
}

func (x *HasWorkspaceBundleRequest) SetDigest(v string) {
	x.Digest = v
}

type HasWorkspaceBundleRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Digest string
}

func (b0 HasWorkspaceBundleRequest_builder) Build() *HasWorkspaceBundleRequest {
	m0 := &HasWorkspaceBundleRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.Digest = b.Digest
	return m0
}

// Response message for checking workspace bundle presence.
type HasWorkspaceBundleResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Exists        bool                   `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HasWorkspaceBundleResponse) Reset() {
	*x = HasWorkspaceBundleResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[28]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HasWorkspaceBundleResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HasWorkspaceBundleResponse) ProtoMessage() {}

func (x *HasWorkspaceBundleResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[28]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *HasWorkspaceBundleResponse) GetExists() bool {
	if x != nil {
		return x.Exists
	}
	return false
}

func (x *HasWorkspaceBundleResponse) SetExists(v bool) {
	x.Exists = v
}

type HasWorkspaceBundleResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Exists bool
}

func (b0 HasWorkspaceBundleResponse_builder) Build() *HasWorkspaceBundleResponse {
	m0 := &HasWorkspaceBundleResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Exists = b.Exists
	return m0
}

// Request message for workspace bundle download.
type GetWorkspaceBundleRequest struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Digest        string                 `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetWorkspaceBundleRequest) Reset() {
	*x = GetWorkspaceBundleRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[29]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetWorkspaceBundleRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetWorkspaceBundleRequest) ProtoMessage() {}

func (x *GetWorkspaceBundleRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[29]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *GetWorkspaceBundleRequest) GetDigest() string {
	if x != nil {
		return x.Digest
	}
	return ""
}

func (x *GetWorkspaceBundleRequest) SetDigest(v string) {
	x.Digest = v
}

type GetWorkspaceBundleRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Digest string
}

func (b0 GetWorkspaceBundleRequest_builder) Build() *GetWorkspaceBundleRequest {
	m0 := &GetWorkspaceBundleRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.Digest = b.Digest
	return m0
}

// Request message for getting DAG run status.
type GetDAGRunStatusRequest struct {
	state    protoimpl.MessageState `protogen:"hybrid.v1"`
	DagName  string                 `protobuf:"bytes,1,opt,name=dag_name,json=dagName,proto3" json:"dag_name,omitempty"`      // Name of the DAG
	DagRunId string                 `protobuf:"bytes,2,opt,name=dag_run_id,json=dagRunId,proto3" json:"dag_run_id,omitempty"` // ID of the DAG run
	// Root DAG run info for sub-DAG queries (optional).
	// When set, the coordinator looks up the status as a sub-DAG.
	RootDagRunName string `protobuf:"bytes,3,opt,name=root_dag_run_name,json=rootDagRunName,proto3" json:"root_dag_run_name,omitempty"`
	RootDagRunId   string `protobuf:"bytes,4,opt,name=root_dag_run_id,json=rootDagRunId,proto3" json:"root_dag_run_id,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *GetDAGRunStatusRequest) Reset() {
	*x = GetDAGRunStatusRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[30]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetDAGRunStatusRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetDAGRunStatusRequest) ProtoMessage() {}

func (x *GetDAGRunStatusRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[30]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *GetDAGRunStatusRequest) GetDagName() string {
	if x != nil {
		return x.DagName
	}
	return ""
}

func (x *GetDAGRunStatusRequest) GetDagRunId() string {
	if x != nil {
		return x.DagRunId
	}
	return ""
}

func (x *GetDAGRunStatusRequest) GetRootDagRunName() string {
	if x != nil {
		return x.RootDagRunName
	}
	return ""
}

func (x *GetDAGRunStatusRequest) GetRootDagRunId() string {
	if x != nil {
		return x.RootDagRunId
	}
	return ""
}

func (x *GetDAGRunStatusRequest) SetDagName(v string) {
	x.DagName = v
}

func (x *GetDAGRunStatusRequest) SetDagRunId(v string) {
	x.DagRunId = v
}

func (x *GetDAGRunStatusRequest) SetRootDagRunName(v string) {
	x.RootDagRunName = v
}

func (x *GetDAGRunStatusRequest) SetRootDagRunId(v string) {
	x.RootDagRunId = v
}

type GetDAGRunStatusRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	DagName  string
	DagRunId string
	// Root DAG run info for sub-DAG queries (optional).
	// When set, the coordinator looks up the status as a sub-DAG.
	RootDagRunName string
	RootDagRunId   string
}

func (b0 GetDAGRunStatusRequest_builder) Build() *GetDAGRunStatusRequest {
	m0 := &GetDAGRunStatusRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.DagName = b.DagName
	x.DagRunId = b.DagRunId
	x.RootDagRunName = b.RootDagRunName
	x.RootDagRunId = b.RootDagRunId
	return m0
}

// Response message for getting DAG run status.
type GetDAGRunStatusResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Found         bool                   `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`  // Whether the DAG run was found
	Status        *DAGRunStatusProto     `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // The status (only set if found)
	Error         string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`   // Error message if any
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetDAGRunStatusResponse) Reset() {
	*x = GetDAGRunStatusResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[31]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetDAGRunStatusResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetDAGRunStatusResponse) ProtoMessage() {}

func (x *GetDAGRunStatusResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[31]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *GetDAGRunStatusResponse) GetFound() bool {
	if x != nil {
		return x.Found
	}
	return false
}

func (x *GetDAGRunStatusResponse) GetStatus() *DAGRunStatusProto {
	if x != nil {
		return x.Status
	}
	return nil
}

func (x *GetDAGRunStatusResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *GetDAGRunStatusResponse) SetFound(v bool) {
	x.Found = v
}

func (x *GetDAGRunStatusResponse) SetStatus(v *DAGRunStatusProto) {
	x.Status = v
}

func (x *GetDAGRunStatusResponse) SetError(v string) {
	x.Error = v
}

func (x *GetDAGRunStatusResponse) HasStatus() bool {
	if x == nil {
		return false
	}
	return x.Status != nil
}

func (x *GetDAGRunStatusResponse) ClearStatus() {
	x.Status = nil
}

type GetDAGRunStatusResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Found  bool
	Status *DAGRunStatusProto
	Error  string
}

func (b0 GetDAGRunStatusResponse_builder) Build() *GetDAGRunStatusResponse {
	m0 := &GetDAGRunStatusResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Found = b.Found
	x.Status = b.Status
	x.Error = b.Error
	return m0
}

// Request message for cancelling a DAG run.
type RequestCancelRequest struct {
	state    protoimpl.MessageState `protogen:"hybrid.v1"`
	DagName  string                 `protobuf:"bytes,1,opt,name=dag_name,json=dagName,proto3" json:"dag_name,omitempty"`
	DagRunId string                 `protobuf:"bytes,2,opt,name=dag_run_id,json=dagRunId,proto3" json:"dag_run_id,omitempty"`
	// Root DAG run info for sub-DAG cancellation
	RootDagRunName string `protobuf:"bytes,3,opt,name=root_dag_run_name,json=rootDagRunName,proto3" json:"root_dag_run_name,omitempty"`
	RootDagRunId   string `protobuf:"bytes,4,opt,name=root_dag_run_id,json=rootDagRunId,proto3" json:"root_dag_run_id,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *RequestCancelRequest) Reset() {
	*x = RequestCancelRequest{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[32]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RequestCancelRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RequestCancelRequest) ProtoMessage() {}

func (x *RequestCancelRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[32]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *RequestCancelRequest) GetDagName() string {
	if x != nil {
		return x.DagName
	}
	return ""
}

func (x *RequestCancelRequest) GetDagRunId() string {
	if x != nil {
		return x.DagRunId
	}
	return ""
}

func (x *RequestCancelRequest) GetRootDagRunName() string {
	if x != nil {
		return x.RootDagRunName
	}
	return ""
}

func (x *RequestCancelRequest) GetRootDagRunId() string {
	if x != nil {
		return x.RootDagRunId
	}
	return ""
}

func (x *RequestCancelRequest) SetDagName(v string) {
	x.DagName = v
}

func (x *RequestCancelRequest) SetDagRunId(v string) {
	x.DagRunId = v
}

func (x *RequestCancelRequest) SetRootDagRunName(v string) {
	x.RootDagRunName = v
}

func (x *RequestCancelRequest) SetRootDagRunId(v string) {
	x.RootDagRunId = v
}

type RequestCancelRequest_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	DagName  string
	DagRunId string
	// Root DAG run info for sub-DAG cancellation
	RootDagRunName string
	RootDagRunId   string
}

func (b0 RequestCancelRequest_builder) Build() *RequestCancelRequest {
	m0 := &RequestCancelRequest{}
	b, x := &b0, m0
	_, _ = b, x
	x.DagName = b.DagName
	x.DagRunId = b.DagRunId
	x.RootDagRunName = b.RootDagRunName
	x.RootDagRunId = b.RootDagRunId
	return m0
}

// Response message for cancelling a DAG run.
type RequestCancelResponse struct {
	state         protoimpl.MessageState `protogen:"hybrid.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Error         string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RequestCancelResponse) Reset() {
	*x = RequestCancelResponse{}
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[33]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RequestCancelResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RequestCancelResponse) ProtoMessage() {}

func (x *RequestCancelResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_coordinator_v1_coordinator_proto_msgTypes[33]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

func (x *RequestCancelResponse) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *RequestCancelResponse) GetError() string {
	if x != nil {
		return x.Error
	}
	return ""
}

func (x *RequestCancelResponse) SetAccepted(v bool) {
	x.Accepted = v
}

func (x *RequestCancelResponse) SetError(v string) {
	x.Error = v
}

type RequestCancelResponse_builder struct {
	_ [0]func() // Prevents comparability and use of unkeyed literals for the builder.

	Accepted bool
	Error    string
}

func (b0 RequestCancelResponse_builder) Build() *RequestCancelResponse {
	m0 := &RequestCancelResponse{}
	b, x := &b0, m0
	_, _ = b, x
	x.Accepted = b.Accepted
	x.Error = b.Error
	return m0
}

var File_proto_coordinator_v1_coordinator_proto protoreflect.FileDescriptor

const file_proto_coordinator_v1_coordinator_proto_rawDesc = "" +
	"\n" +
	"&proto/coordinator/v1/coordinator.proto\x12\x0ecoordinator.v1\"\xc3\x01\n" +
	"\vPollRequest\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x12\x1b\n" +
	"\tpoller_id\x18\x02 \x01(\tR\bpollerId\x12?\n" +
	"\x06labels\x18\x03 \x03(\v2'.coordinator.v1.PollRequest.LabelsEntryR\x06labels\x1a9\n" +
	"\vLabelsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"8\n" +
	"\fPollResponse\x12(\n" +
	"\x04task\x18\x01 \x01(\v2\x14.coordinator.v1.TaskR\x04task\";\n" +
	"\x0fDispatchRequest\x12(\n" +
	"\x04task\x18\x01 \x01(\v2\x14.coordinator.v1.TaskR\x04task\"\x12\n" +
	"\x10DispatchResponse\"\x8d\v\n" +
	"\x04Task\x127\n" +
	"\toperation\x18\x06 \x01(\x0e2\x19.coordinator.v1.OperationR\toperation\x12)\n" +
	"\x11root_dag_run_name\x18\x01 \x01(\tR\x0erootDagRunName\x12%\n" +
	"\x0froot_dag_run_id\x18\x02 \x01(\tR\frootDagRunId\x12-\n" +
	"\x13parent_dag_run_name\x18\x03 \x01(\tR\x10parentDagRunName\x12)\n" +
	"\x11parent_dag_run_id\x18\x04 \x01(\tR\x0eparentDagRunId\x12\x1c\n" +
	"\n" +
	"dag_run_id\x18\x05 \x01(\tR\bdagRunId\x12\x16\n" +
	"\x06target\x18\a \x01(\tR\x06target\x12\x16\n" +
	"\x06params\x18\b \x01(\tR\x06params\x12\x12\n" +
	"\x04step\x18\t \x01(\tR\x04step\x12Q\n" +
	"\x0fworker_selector\x18\n" +
	" \x03(\v2(.coordinator.v1.Task.WorkerSelectorEntryR\x0eworkerSelector\x12\x1e\n" +
	"\n" +
	"definition\x18\v \x01(\tR\n" +
	"definition\x12\x1b\n" +
	"\tworker_id\x18\f \x01(\tR\bworkerId\x12J\n" +
	"\x0fprevious_status\x18\r \x01(\v2!.coordinator.v1.DAGRunStatusProtoR\x0epreviousStatus\x12\x1d\n" +
	"\n" +
	"attempt_id\x18\x0e \x01(\tR\tattemptId\x12\x1f\n" +
	"\vattempt_key\x18\x0f \x01(\tR\n" +
	"attemptKey\x12\x16\n" +
	"\x06labels\x18\x10 \x01(\tR\x06labels\x12\x1f\n" +
	"\vbase_config\x18\x11 \x01(\tR\n" +
	"baseConfig\x12#\n" +
	"\rschedule_time\x18\x12 \x01(\tR\fscheduleTime\x12.\n" +
	"\x13external_step_retry\x18\x13 \x01(\bR\x11externalStepRetry\x12\x1d\n" +
	"\n" +
	"queue_name\x18\x14 \x01(\tR\tqueueName\x120\n" +
	"\x14owner_coordinator_id\x18\x15 \x01(\tR\x12ownerCoordinatorId\x124\n" +
	"\x16owner_coordinator_host\x18\x16 \x01(\tR\x14ownerCoordinatorHost\x124\n" +
	"\x16owner_coordinator_port\x18\x17 \x01(\x05R\x14ownerCoordinatorPort\x12\x1f\n" +
	"\vclaim_token\x18\x18 \x01(\tR\n" +
	"claimToken\x12\x1f\n" +
	"\vsource_file\x18\x19 \x01(\tR\n" +
	"sourceFile\x12%\n" +
	"\x0eagent_snapshot\x18\x1a \x01(\fR\ragentSnapshot\x126\n" +
	"\x17workspace_bundle_digest\x18\x1b \x01(\tR\x15workspaceBundleDigest\x122\n" +
	"\x15workspace_bundle_size\x18\x1c \x01(\x03R\x13workspaceBundleSize\x129\n" +
	"\x19workspace_bundle_dag_path\x18\x1d \x01(\tR\x16workspaceBundleDagPath\x12A\n" +
	"\x1dworkspace_bundle_original_ref\x18\x1e \x01(\tR\x1aworkspaceBundleOriginalRef\x12A\n" +
	"\x1dworkspace_bundle_resolved_ref\x18\x1f \x01(\tR\x1aworkspaceBundleResolvedRef\x1aA\n" +
	"\x13WorkerSelectorEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\x13\n" +
	"\x11GetWorkersRequest\"J\n" +
	"\x12GetWorkersResponse\x124\n" +
	"\aworkers\x18\x01 \x03(\v2\x1a.coordinator.v1.WorkerInfoR\aworkers\"\xe3\x03\n" +
	"\n" +
	"WorkerInfo\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x12\x1b\n" +
	"\tpoller_id\x18\x02 \x01(\tR\bpollerId\x12>\n" +
	"\x06labels\x18\x03 \x03(\v2&.coordinator.v1.WorkerInfo.LabelsEntryR\x06labels\x12!\n" +
	"\fconnected_at\x18\x04 \x01(\x03R\vconnectedAt\x12#\n" +
	"\rtotal_pollers\x18\x05 \x01(\x05R\ftotalPollers\x12!\n" +
	"\fbusy_pollers\x18\x06 \x01(\x05R\vbusyPollers\x12@\n" +
	"\rrunning_tasks\x18\a \x03(\v2\x1b.coordinator.v1.RunningTaskR\frunningTasks\x12*\n" +
	"\x11last_heartbeat_at\x18\b \x01(\x03R\x0flastHeartbeatAt\x12G\n" +
	"\rhealth_status\x18\t \x01(\x0e2\".coordinator.v1.WorkerHealthStatusR\fhealthStatus\x1a9\n" +
	"\vLabelsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\xe3\x01\n" +
	"\x10HeartbeatRequest\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x12D\n" +
	"\x06labels\x18\x02 \x03(\v2,.coordinator.v1.HeartbeatRequest.LabelsEntryR\x06labels\x121\n" +
	"\x05stats\x18\x03 \x01(\v2\x1b.coordinator.v1.WorkerStatsR\x05stats\x1a9\n" +
	"\vLabelsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"X\n" +
	"\x11HeartbeatResponse\x12C\n" +
	"\x0ecancelled_runs\x18\x01 \x03(\v2\x1c.coordinator.v1.CancelledRunR\rcancelledRuns\"S\n" +
	"\x13AckTaskClaimRequest\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x12\x1f\n" +
	"\vclaim_token\x18\x02 \x01(\tR\n" +
	"claimToken\"H\n" +
	"\x14AckTaskClaimResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12\x14\n" +
	"\x05error\x18\x02 \x01(\tR\x05error\"\xa6\x01\n" +
	"\x13RunHeartbeatRequest\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x120\n" +
	"\x14owner_coordinator_id\x18\x02 \x01(\tR\x12ownerCoordinatorId\x12@\n" +
	"\rrunning_tasks\x18\x03 \x03(\v2\x1b.coordinator.v1.RunningTaskR\frunningTasks\"[\n" +
	"\x14RunHeartbeatResponse\x12C\n" +
	"\x0ecancelled_runs\x18\x01 \x03(\v2\x1c.coordinator.v1.CancelledRunR\rcancelledRuns\"/\n" +
	"\fCancelledRun\x12\x1f\n" +
	"\vattempt_key\x18\x01 \x01(\tR\n" +
	"attemptKey\"\x97\x01\n" +
	"\vWorkerStats\x12#\n" +
	"\rtotal_pollers\x18\x01 \x01(\x05R\ftotalPollers\x12!\n" +
	"\fbusy_pollers\x18\x02 \x01(\x05R\vbusyPollers\x12@\n" +
	"\rrunning_tasks\x18\x03 \x03(\v2\x1b.coordinator.v1.RunningTaskR\frunningTasks\"\xb2\x02\n" +
	"\vRunningTask\x12\x1c\n" +
	"\n" +
	"dag_run_id\x18\x01 \x01(\tR\bdagRunId\x12\x19\n" +
	"\bdag_name\x18\x02 \x01(\tR\adagName\x12\x1d\n" +
	"\n" +
	"started_at\x18\x03 \x01(\x03R\tstartedAt\x12)\n" +
	"\x11root_dag_run_name\x18\x04 \x01(\tR\x0erootDagRunName\x12%\n" +
	"\x0froot_dag_run_id\x18\x05 \x01(\tR\frootDagRunId\x12-\n" +
	"\x13parent_dag_run_name\x18\x06 \x01(\tR\x10parentDagRunName\x12)\n" +
	"\x11parent_dag_run_id\x18\a \x01(\tR\x0eparentDagRunId\x12\x1f\n" +
	"\vattempt_key\x18\b \x01(\tR\n" +
	"attemptKey\"\x9f\x01\n" +
	"\x13ReportStatusRequest\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x129\n" +
	"\x06status\x18\x02 \x01(\v2!.coordinator.v1.DAGRunStatusProtoR\x06status\x120\n" +
	"\x14owner_coordinator_id\x18\x03 \x01(\tR\x12ownerCoordinatorId\"H\n" +
	"\x14ReportStatusResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12\x14\n" +
	"\x05error\x18\x02 \x01(\tR\x05error\"0\n" +
	"\x11DAGRunStatusProto\x12\x1b\n" +
	"\tjson_data\x18\x01 \x01(\tR\bjsonData\"\xab\x03\n" +
	"\bLogChunk\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x12\x1c\n" +
	"\n" +
	"dag_run_id\x18\x02 \x01(\tR\bdagRunId\x12\x19\n" +
	"\bdag_name\x18\x03 \x01(\tR\adagName\x12\x1b\n" +
	"\tstep_name\x18\x04 \x01(\tR\bstepName\x12>\n" +
	"\vstream_type\x18\x05 \x01(\x0e2\x1d.coordinator.v1.LogStreamTypeR\n" +
	"streamType\x12\x12\n" +
	"\x04data\x18\x06 \x01(\fR\x04data\x12\x1a\n" +
	"\bsequence\x18\a \x01(\x04R\bsequence\x12\x19\n" +
	"\bis_final\x18\b \x01(\bR\aisFinal\x12)\n" +
	"\x11root_dag_run_name\x18\t \x01(\tR\x0erootDagRunName\x12%\n" +
	"\x0froot_dag_run_id\x18\n" +
	" \x01(\tR\frootDagRunId\x12\x1d\n" +
	"\n" +
	"attempt_id\x18\v \x01(\tR\tattemptId\x120\n" +
	"\x14owner_coordinator_id\x18\f \x01(\tR\x12ownerCoordinatorId\"x\n" +
	"\x12StreamLogsResponse\x12'\n" +
	"\x0fchunks_received\x18\x01 \x01(\x04R\x0echunksReceived\x12#\n" +
	"\rbytes_written\x18\x02 \x01(\x04R\fbytesWritten\x12\x14\n" +
	"\x05error\x18\x03 \x01(\tR\x05error\"\xf8\x02\n" +
	"\rArtifactChunk\x12\x1b\n" +
	"\tworker_id\x18\x01 \x01(\tR\bworkerId\x12\x1c\n" +
	"\n" +
	"dag_run_id\x18\x02 \x01(\tR\bdagRunId\x12\x19\n" +
	"\bdag_name\x18\x03 \x01(\tR\adagName\x12#\n" +
	"\rrelative_path\x18\x04 \x01(\tR\frelativePath\x12\x12\n" +
	"\x04data\x18\x05 \x01(\fR\x04data\x12\x1a\n" +
	"\bsequence\x18\x06 \x01(\x04R\bsequence\x12\x19\n" +
	"\bis_final\x18\a \x01(\bR\aisFinal\x12)\n" +
	"\x11root_dag_run_name\x18\b \x01(\tR\x0erootDagRunName\x12%\n" +
	"\x0froot_dag_run_id\x18\t \x01(\tR\frootDagRunId\x12\x1d\n" +
	"\n" +
	"attempt_id\x18\n" +
	" \x01(\tR\tattemptId\x120\n" +
	"\x14owner_coordinator_id\x18\v \x01(\tR\x12ownerCoordinatorId\"}\n" +
	"\x17StreamArtifactsResponse\x12'\n" +
	"\x0fchunks_received\x18\x01 \x01(\x04R\x0echunksReceived\x12#\n" +
	"\rbytes_written\x18\x02 \x01(\x04R\fbytesWritten\x12\x14\n" +
	"\x05error\x18\x03 \x01(\tR\x05error\"\x9e\x01\n" +
	"\x0fWorkspaceBundle\x12\x16\n" +
	"\x06digest\x18\x01 \x01(\tR\x06digest\x12\x12\n" +
	"\x04size\x18\x02 \x01(\x03R\x04size\x12\x19\n" +
	"\bdag_path\x18\x03 \x01(\tR\adagPath\x12!\n" +
	"\foriginal_ref\x18\x04 \x01(\tR\voriginalRef\x12!\n" +
	"\fresolved_ref\x18\x05 \x01(\tR\vresolvedRef\"\x9a\x01\n" +
	"\x14WorkspaceBundleChunk\x127\n" +
	"\x06bundle\x18\x01 \x01(\v2\x1f.coordinator.v1.WorkspaceBundleR\x06bundle\x12\x12\n" +
	"\x04data\x18\x02 \x01(\fR\x04data\x12\x1a\n" +
	"\bsequence\x18\x03 \x01(\x04R\bsequence\x12\x19\n" +
	"\bis_final\x18\x04 \x01(\bR\aisFinal\"N\n" +
	"\x1aPutWorkspaceBundleResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12\x14\n" +
	"\x05error\x18\x02 \x01(\tR\x05error\"3\n" +
	"\x19HasWorkspaceBundleRequest\x12\x16\n" +
	"\x06digest\x18\x01 \x01(\tR\x06digest\"4\n" +
	"\x1aHasWorkspaceBundleResponse\x12\x16\n" +
	"\x06exists\x18\x01 \x01(\bR\x06exists\"3\n" +
	"\x19GetWorkspaceBundleRequest\x12\x16\n" +
	"\x06digest\x18\x01 \x01(\tR\x06digest\"\xa3\x01\n" +
	"\x16GetDAGRunStatusRequest\x12\x19\n" +
	"\bdag_name\x18\x01 \x01(\tR\adagName\x12\x1c\n" +
	"\n" +
	"dag_run_id\x18\x02 \x01(\tR\bdagRunId\x12)\n" +
	"\x11root_dag_run_name\x18\x03 \x01(\tR\x0erootDagRunName\x12%\n" +
	"\x0froot_dag_run_id\x18\x04 \x01(\tR\frootDagRunId\"\x80\x01\n" +
	"\x17GetDAGRunStatusResponse\x12\x14\n" +
	"\x05found\x18\x01 \x01(\bR\x05found\x129\n" +
	"\x06status\x18\x02 \x01(\v2!.coordinator.v1.DAGRunStatusProtoR\x06status\x12\x14\n" +
	"\x05error\x18\x03 \x01(\tR\x05error\"\xa1\x01\n" +
	"\x14RequestCancelRequest\x12\x19\n" +
	"\bdag_name\x18\x01 \x01(\tR\adagName\x12\x1c\n" +
	"\n" +
	"dag_run_id\x18\x02 \x01(\tR\bdagRunId\x12)\n" +
	"\x11root_dag_run_name\x18\x03 \x01(\tR\x0erootDagRunName\x12%\n" +
	"\x0froot_dag_run_id\x18\x04 \x01(\tR\frootDagRunId\"I\n" +
	"\x15RequestCancelResponse\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12\x14\n" +
	"\x05error\x18\x02 \x01(\tR\x05error*P\n" +
	"\tOperation\x12\x19\n" +
	"\x15OPERATION_UNSPECIFIED\x10\x00\x12\x13\n" +
	"\x0fOPERATION_START\x10\x01\x12\x13\n" +
	"\x0fOPERATION_RETRY\x10\x02*\xa2\x01\n" +
	"\x12WorkerHealthStatus\x12$\n" +
	" WORKER_HEALTH_STATUS_UNSPECIFIED\x10\x00\x12 \n" +
	"\x1cWORKER_HEALTH_STATUS_HEALTHY\x10\x01\x12 \n" +
	"\x1cWORKER_HEALTH_STATUS_WARNING\x10\x02\x12\"\n" +
	"\x1eWORKER_HEALTH_STATUS_UNHEALTHY\x10\x03*\x87\x01\n" +
	"\rLogStreamType\x12\x1f\n" +
	"\x1bLOG_STREAM_TYPE_UNSPECIFIED\x10\x00\x12\x1a\n" +
	"\x16LOG_STREAM_TYPE_STDOUT\x10\x01\x12\x1a\n" +
	"\x16LOG_STREAM_TYPE_STDERR\x10\x02\x12\x1d\n" +
	"\x19LOG_STREAM_TYPE_SCHEDULER\x10\x032\x8b\n" +
	"\n" +
	"\x12CoordinatorService\x12A\n" +
	"\x04Poll\x12\x1b.coordinator.v1.PollRequest\x1a\x1c.coordinator.v1.PollResponse\x12M\n" +
	"\bDispatch\x12\x1f.coordinator.v1.DispatchRequest\x1a .coordinator.v1.DispatchResponse\x12S\n" +
	"\n" +
	"GetWorkers\x12!.coordinator.v1.GetWorkersRequest\x1a\".coordinator.v1.GetWorkersResponse\x12P\n" +
	"\tHeartbeat\x12 .coordinator.v1.HeartbeatRequest\x1a!.coordinator.v1.HeartbeatResponse\x12Y\n" +
	"\fAckTaskClaim\x12#.coordinator.v1.AckTaskClaimRequest\x1a$.coordinator.v1.AckTaskClaimResponse\x12Y\n" +
	"\fRunHeartbeat\x12#.coordinator.v1.RunHeartbeatRequest\x1a$.coordinator.v1.RunHeartbeatResponse\x12Y\n" +
	"\fReportStatus\x12#.coordinator.v1.ReportStatusRequest\x1a$.coordinator.v1.ReportStatusResponse\x12L\n" +
	"\n" +
	"StreamLogs\x12\x18.coordinator.v1.LogChunk\x1a\".coordinator.v1.StreamLogsResponse(\x01\x12[\n" +
	"\x0fStreamArtifacts\x12\x1d.coordinator.v1.ArtifactChunk\x1a'.coordinator.v1.StreamArtifactsResponse(\x01\x12h\n" +
	"\x12PutWorkspaceBundle\x12$.coordinator.v1.WorkspaceBundleChunk\x1a*.coordinator.v1.PutWorkspaceBundleResponse(\x01\x12k\n" +
	"\x12HasWorkspaceBundle\x12).coordinator.v1.HasWorkspaceBundleRequest\x1a*.coordinator.v1.HasWorkspaceBundleResponse\x12g\n" +
	"\x12GetWorkspaceBundle\x12).coordinator.v1.GetWorkspaceBundleRequest\x1a$.coordinator.v1.WorkspaceBundleChunk0\x01\x12b\n" +
	"\x0fGetDAGRunStatus\x12&.coordinator.v1.GetDAGRunStatusRequest\x1a'.coordinator.v1.GetDAGRunStatusResponse\x12\\\n" +
	"\rRequestCancel\x12$.coordinator.v1.RequestCancelRequest\x1a%.coordinator.v1.RequestCancelResponseB>Z<github.com/dagucloud/dagu/proto/coordinator/v1;coordinatorv1b\x06proto3"

var file_proto_coordinator_v1_coordinator_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
var file_proto_coordinator_v1_coordinator_proto_msgTypes = make([]protoimpl.MessageInfo, 38)
var file_proto_coordinator_v1_coordinator_proto_goTypes = []any{
	(Operation)(0),                     // 0: coordinator.v1.Operation
	(WorkerHealthStatus)(0),            // 1: coordinator.v1.WorkerHealthStatus
	(LogStreamType)(0),                 // 2: coordinator.v1.LogStreamType
	(*PollRequest)(nil),                // 3: coordinator.v1.PollRequest
	(*PollResponse)(nil),               // 4: coordinator.v1.PollResponse
	(*DispatchRequest)(nil),            // 5: coordinator.v1.DispatchRequest
	(*DispatchResponse)(nil),           // 6: coordinator.v1.DispatchResponse
	(*Task)(nil),                       // 7: coordinator.v1.Task
	(*GetWorkersRequest)(nil),          // 8: coordinator.v1.GetWorkersRequest
	(*GetWorkersResponse)(nil),         // 9: coordinator.v1.GetWorkersResponse
	(*WorkerInfo)(nil),                 // 10: coordinator.v1.WorkerInfo
	(*HeartbeatRequest)(nil),           // 11: coordinator.v1.HeartbeatRequest
	(*HeartbeatResponse)(nil),          // 12: coordinator.v1.HeartbeatResponse
	(*AckTaskClaimRequest)(nil),        // 13: coordinator.v1.AckTaskClaimRequest
	(*AckTaskClaimResponse)(nil),       // 14: coordinator.v1.AckTaskClaimResponse
	(*RunHeartbeatRequest)(nil),        // 15: coordinator.v1.RunHeartbeatRequest
	(*RunHeartbeatResponse)(nil),       // 16: coordinator.v1.RunHeartbeatResponse
	(*CancelledRun)(nil),               // 17: coordinator.v1.CancelledRun
	(*WorkerStats)(nil),                // 18: coordinator.v1.WorkerStats
	(*RunningTask)(nil),                // 19: coordinator.v1.RunningTask
	(*ReportStatusRequest)(nil),        // 20: coordinator.v1.ReportStatusRequest
	(*ReportStatusResponse)(nil),       // 21: coordinator.v1.ReportStatusResponse
	(*DAGRunStatusProto)(nil),          // 22: coordinator.v1.DAGRunStatusProto
	(*LogChunk)(nil),                   // 23: coordinator.v1.LogChunk
	(*StreamLogsResponse)(nil),         // 24: coordinator.v1.StreamLogsResponse
	(*ArtifactChunk)(nil),              // 25: coordinator.v1.ArtifactChunk
	(*StreamArtifactsResponse)(nil),    // 26: coordinator.v1.StreamArtifactsResponse
	(*WorkspaceBundle)(nil),            // 27: coordinator.v1.WorkspaceBundle
	(*WorkspaceBundleChunk)(nil),       // 28: coordinator.v1.WorkspaceBundleChunk
	(*PutWorkspaceBundleResponse)(nil), // 29: coordinator.v1.PutWorkspaceBundleResponse
	(*HasWorkspaceBundleRequest)(nil),  // 30: coordinator.v1.HasWorkspaceBundleRequest
	(*HasWorkspaceBundleResponse)(nil), // 31: coordinator.v1.HasWorkspaceBundleResponse
	(*GetWorkspaceBundleRequest)(nil),  // 32: coordinator.v1.GetWorkspaceBundleRequest
	(*GetDAGRunStatusRequest)(nil),     // 33: coordinator.v1.GetDAGRunStatusRequest
	(*GetDAGRunStatusResponse)(nil),    // 34: coordinator.v1.GetDAGRunStatusResponse
	(*RequestCancelRequest)(nil),       // 35: coordinator.v1.RequestCancelRequest
	(*RequestCancelResponse)(nil),      // 36: coordinator.v1.RequestCancelResponse
	nil,                                // 37: coordinator.v1.PollRequest.LabelsEntry
	nil,                                // 38: coordinator.v1.Task.WorkerSelectorEntry
	nil,                                // 39: coordinator.v1.WorkerInfo.LabelsEntry
	nil,                                // 40: coordinator.v1.HeartbeatRequest.LabelsEntry
}
var file_proto_coordinator_v1_coordinator_proto_depIdxs = []int32{
	37, // 0: coordinator.v1.PollRequest.labels:type_name -> coordinator.v1.PollRequest.LabelsEntry
	7,  // 1: coordinator.v1.PollResponse.task:type_name -> coordinator.v1.Task
	7,  // 2: coordinator.v1.DispatchRequest.task:type_name -> coordinator.v1.Task
	0,  // 3: coordinator.v1.Task.operation:type_name -> coordinator.v1.Operation
	38, // 4: coordinator.v1.Task.worker_selector:type_name -> coordinator.v1.Task.WorkerSelectorEntry
	22, // 5: coordinator.v1.Task.previous_status:type_name -> coordinator.v1.DAGRunStatusProto
	10, // 6: coordinator.v1.GetWorkersResponse.workers:type_name -> coordinator.v1.WorkerInfo
	39, // 7: coordinator.v1.WorkerInfo.labels:type_name -> coordinator.v1.WorkerInfo.LabelsEntry
	19, // 8: coordinator.v1.WorkerInfo.running_tasks:type_name -> coordinator.v1.RunningTask
	1,  // 9: coordinator.v1.WorkerInfo.health_status:type_name -> coordinator.v1.WorkerHealthStatus
	40, // 10: coordinator.v1.HeartbeatRequest.labels:type_name -> coordinator.v1.HeartbeatRequest.LabelsEntry
	18, // 11: coordinator.v1.HeartbeatRequest.stats:type_name -> coordinator.v1.WorkerStats
	17, // 12: coordinator.v1.HeartbeatResponse.cancelled_runs:type_name -> coordinator.v1.CancelledRun
	19, // 13: coordinator.v1.RunHeartbeatRequest.running_tasks:type_name -> coordinator.v1.RunningTask
	17, // 14: coordinator.v1.RunHeartbeatResponse.cancelled_runs:type_name -> coordinator.v1.CancelledRun
	19, // 15: coordinator.v1.WorkerStats.running_tasks:type_name -> coordinator.v1.RunningTask
	22, // 16: coordinator.v1.ReportStatusRequest.status:type_name -> coordinator.v1.DAGRunStatusProto
	2,  // 17: coordinator.v1.LogChunk.stream_type:type_name -> coordinator.v1.LogStreamType
	27, // 18: coordinator.v1.WorkspaceBundleChunk.bundle:type_name -> coordinator.v1.WorkspaceBundle
	22, // 19: coordinator.v1.GetDAGRunStatusResponse.status:type_name -> coordinator.v1.DAGRunStatusProto
	3,  // 20: coordinator.v1.CoordinatorService.Poll:input_type -> coordinator.v1.PollRequest
	5,  // 21: coordinator.v1.CoordinatorService.Dispatch:input_type -> coordinator.v1.DispatchRequest
	8,  // 22: coordinator.v1.CoordinatorService.GetWorkers:input_type -> coordinator.v1.GetWorkersRequest
	11, // 23: coordinator.v1.CoordinatorService.Heartbeat:input_type -> coordinator.v1.HeartbeatRequest
	13, // 24: coordinator.v1.CoordinatorService.AckTaskClaim:input_type -> coordinator.v1.AckTaskClaimRequest
	15, // 25: coordinator.v1.CoordinatorService.RunHeartbeat:input_type -> coordinator.v1.RunHeartbeatRequest
	20, // 26: coordinator.v1.CoordinatorService.ReportStatus:input_type -> coordinator.v1.ReportStatusRequest
	23, // 27: coordinator.v1.CoordinatorService.StreamLogs:input_type -> coordinator.v1.LogChunk
	25, // 28: coordinator.v1.CoordinatorService.StreamArtifacts:input_type -> coordinator.v1.ArtifactChunk
	28, // 29: coordinator.v1.CoordinatorService.PutWorkspaceBundle:input_type -> coordinator.v1.WorkspaceBundleChunk
	30, // 30: coordinator.v1.CoordinatorService.HasWorkspaceBundle:input_type -> coordinator.v1.HasWorkspaceBundleRequest
	32, // 31: coordinator.v1.CoordinatorService.GetWorkspaceBundle:input_type -> coordinator.v1.GetWorkspaceBundleRequest
	33, // 32: coordinator.v1.CoordinatorService.GetDAGRunStatus:input_type -> coordinator.v1.GetDAGRunStatusRequest
	35, // 33: coordinator.v1.CoordinatorService.RequestCancel:input_type -> coordinator.v1.RequestCancelRequest
	4,  // 34: coordinator.v1.CoordinatorService.Poll:output_type -> coordinator.v1.PollResponse
	6,  // 35: coordinator.v1.CoordinatorService.Dispatch:output_type -> coordinator.v1.DispatchResponse
	9,  // 36: coordinator.v1.CoordinatorService.GetWorkers:output_type -> coordinator.v1.GetWorkersResponse
	12, // 37: coordinator.v1.CoordinatorService.Heartbeat:output_type -> coordinator.v1.HeartbeatResponse
	14, // 38: coordinator.v1.CoordinatorService.AckTaskClaim:output_type -> coordinator.v1.AckTaskClaimResponse
	16, // 39: coordinator.v1.CoordinatorService.RunHeartbeat:output_type -> coordinator.v1.RunHeartbeatResponse
	21, // 40: coordinator.v1.CoordinatorService.ReportStatus:output_type -> coordinator.v1.ReportStatusResponse
	24, // 41: coordinator.v1.CoordinatorService.StreamLogs:output_type -> coordinator.v1.StreamLogsResponse
	26, // 42: coordinator.v1.CoordinatorService.StreamArtifacts:output_type -> coordinator.v1.StreamArtifactsResponse
	29, // 43: coordinator.v1.CoordinatorService.PutWorkspaceBundle:output_type -> coordinator.v1.PutWorkspaceBundleResponse
	31, // 44: coordinator.v1.CoordinatorService.HasWorkspaceBundle:output_type -> coordinator.v1.HasWorkspaceBundleResponse
	28, // 45: coordinator.v1.CoordinatorService.GetWorkspaceBundle:output_type -> coordinator.v1.WorkspaceBundleChunk
	34, // 46: coordinator.v1.CoordinatorService.GetDAGRunStatus:output_type -> coordinator.v1.GetDAGRunStatusResponse
	36, // 47: coordinator.v1.CoordinatorService.RequestCancel:output_type -> coordinator.v1.RequestCancelResponse
	34, // [34:48] is the sub-list for method output_type
	20, // [20:34] is the sub-list for method input_type
	20, // [20:20] is the sub-list for extension type_name
	20, // [20:20] is the sub-list for extension extendee
	0,  // [0:20] is the sub-list for field type_name
}

func init() { file_proto_coordinator_v1_coordinator_proto_init() }
func file_proto_coordinator_v1_coordinator_proto_init() {
	if File_proto_coordinator_v1_coordinator_proto != nil {
		return
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_proto_coordinator_v1_coordinator_proto_rawDesc), len(file_proto_coordinator_v1_coordinator_proto_rawDesc)),
			NumEnums:      3,
			NumMessages:   38,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_proto_coordinator_v1_coordinator_proto_goTypes,
		DependencyIndexes: file_proto_coordinator_v1_coordinator_proto_depIdxs,
		EnumInfos:         file_proto_coordinator_v1_coordinator_proto_enumTypes,
		MessageInfos:      file_proto_coordinator_v1_coordinator_proto_msgTypes,
	}.Build()
	File_proto_coordinator_v1_coordinator_proto = out.File
	file_proto_coordinator_v1_coordinator_proto_goTypes = nil
	file_proto_coordinator_v1_coordinator_proto_depIdxs = nil
}
