jobs

Feb 3, 2025

Changes in this version

type BaseRun

+ EffectivePerformanceTarget PerformanceTarget

type CreateJob

+ PerformanceTarget PerformanceTarget

type JobSettings

+ PerformanceTarget PerformanceTarget

+ type PerformanceTarget string

+ const PerformanceTargetCostOptimized

+ const PerformanceTargetPerformanceOptimized

+ func (f *PerformanceTarget) Set(v string) error

+ func (f *PerformanceTarget) String() string

+ func (f *PerformanceTarget) Type() string

type Run

+ EffectivePerformanceTarget PerformanceTarget

type RunNow

+ PerformanceTarget PerformanceTarget

type RunTask

+ Disabled bool

+ EffectivePerformanceTarget PerformanceTarget

type TerminationCodeCode

+ const TerminationCodeCodeBudgetPolicyLimitExceeded

Jan 22, 2025

Changes in this version

type CleanRoomTaskRunLifeCycleState

+ const CleanRoomTaskRunLifeCycleStateRunLifeCycleStateUnspecified

type CleanRoomTaskRunResultState

+ const CleanRoomTaskRunResultStateRunResultStateUnspecified

+ type CleanRoomsNotebookTaskCleanRoomsNotebookTaskOutput struct

+ CleanRoomJobRunState *CleanRoomTaskRunState

+ NotebookOutput *NotebookOutput

+ OutputSchemaInfo *OutputSchemaInfo

+ type OutputSchemaInfo struct

+ CatalogName string

+ ExpirationTime int64

+ ForceSendFields []string

+ SchemaName string

+ func (s *OutputSchemaInfo) UnmarshalJSON(b []byte) error

+ func (s OutputSchemaInfo) MarshalJSON() ([]byte, error)

type RunOutput

+ CleanRoomsNotebookOutput *CleanRoomsNotebookTaskCleanRoomsNotebookTaskOutput

type SparkJarTask

+ RunAsRepl bool

Jan 13, 2025

Changes in this version

type BaseJob

+ HasMore bool

type BaseRun

+ HasMore bool

type GetJobRequest

+ ForceSendFields []string

+ PageToken string

+ func (s *GetJobRequest) UnmarshalJSON(b []byte) error

+ func (s GetJobRequest) MarshalJSON() ([]byte, error)

type Job

+ HasMore bool

+ NextPageToken string

type Run

+ HasMore bool

Dec 17, 2024

Changes in this version

+ type CleanRoomsNotebookTask struct

+ CleanRoomName string

+ Etag string

+ ForceSendFields []string

+ NotebookBaseParameters map[string]string

+ NotebookName string

+ func (s *CleanRoomsNotebookTask) UnmarshalJSON(b []byte) error

+ func (s CleanRoomsNotebookTask) MarshalJSON() ([]byte, error)

type RunTask

+ CleanRoomsNotebookTask *CleanRoomsNotebookTask

type SubmitTask

+ CleanRoomsNotebookTask *CleanRoomsNotebookTask

type Task

+ CleanRoomsNotebookTask *CleanRoomsNotebookTask

Dec 5, 2024

Changes in this version

+ type CleanRoomTaskRunLifeCycleState string

+ const CleanRoomTaskRunLifeCycleStateBlocked

+ const CleanRoomTaskRunLifeCycleStateInternalError

+ const CleanRoomTaskRunLifeCycleStatePending

+ const CleanRoomTaskRunLifeCycleStateQueued

+ const CleanRoomTaskRunLifeCycleStateRunning

+ const CleanRoomTaskRunLifeCycleStateSkipped

+ const CleanRoomTaskRunLifeCycleStateTerminated

+ const CleanRoomTaskRunLifeCycleStateTerminating

+ const CleanRoomTaskRunLifeCycleStateWaitingForRetry

+ func (f *CleanRoomTaskRunLifeCycleState) Set(v string) error

+ func (f *CleanRoomTaskRunLifeCycleState) String() string

+ func (f *CleanRoomTaskRunLifeCycleState) Type() string

+ type CleanRoomTaskRunResultState string

+ const CleanRoomTaskRunResultStateCanceled

+ const CleanRoomTaskRunResultStateDisabled

+ const CleanRoomTaskRunResultStateEvicted

+ const CleanRoomTaskRunResultStateExcluded

+ const CleanRoomTaskRunResultStateFailed

+ const CleanRoomTaskRunResultStateMaximumConcurrentRunsReached

+ const CleanRoomTaskRunResultStateSuccess

+ const CleanRoomTaskRunResultStateSuccessWithFailures

+ const CleanRoomTaskRunResultStateTimedout

+ const CleanRoomTaskRunResultStateUpstreamCanceled

+ const CleanRoomTaskRunResultStateUpstreamEvicted

+ const CleanRoomTaskRunResultStateUpstreamFailed

+ func (f *CleanRoomTaskRunResultState) Set(v string) error

+ func (f *CleanRoomTaskRunResultState) String() string

+ func (f *CleanRoomTaskRunResultState) Type() string

+ type CleanRoomTaskRunState struct

+ LifeCycleState CleanRoomTaskRunLifeCycleState

+ ResultState CleanRoomTaskRunResultState

Nov 7, 2024

Changes in this version

type RunNow

+ Only []string

Oct 14, 2024

Changes in this version

type BaseJob

+ EffectiveBudgetPolicyId string

type CreateJob

+ BudgetPolicyId string

type Job

+ EffectiveBudgetPolicyId string

type JobSettings

+ BudgetPolicyId string

type SubmitRun

+ BudgetPolicyId string

Oct 3, 2024

Changes in this version

type TerminationCodeCode

+ const TerminationCodeCodeUserCanceled

Oct 1, 2024

Changes in this version

type RunResultState

+ const RunResultStateDisabled

Sep 4, 2024

Changes in this version

type BaseRun

+ Status *RunStatus

+ type QueueDetails struct

+ Code QueueDetailsCodeCode

+ ForceSendFields []string

+ Message string

+ func (s *QueueDetails) UnmarshalJSON(b []byte) error

+ func (s QueueDetails) MarshalJSON() ([]byte, error)

+ type QueueDetailsCodeCode string

+ const QueueDetailsCodeCodeActiveRunJobTasksLimitReached

+ const QueueDetailsCodeCodeActiveRunsLimitReached

+ const QueueDetailsCodeCodeMaxConcurrentRunsReached

+ func (f *QueueDetailsCodeCode) Set(v string) error

+ func (f *QueueDetailsCodeCode) String() string

+ func (f *QueueDetailsCodeCode) Type() string

type RepairHistoryItem

+ Status *RunStatus

type Run

+ Status *RunStatus

+ type RunLifecycleStateV2State string

+ const RunLifecycleStateV2StateBlocked

+ const RunLifecycleStateV2StatePending

+ const RunLifecycleStateV2StateQueued

+ const RunLifecycleStateV2StateRunning

+ const RunLifecycleStateV2StateTerminated

+ const RunLifecycleStateV2StateTerminating

+ func (f *RunLifecycleStateV2State) Set(v string) error

+ func (f *RunLifecycleStateV2State) String() string

+ func (f *RunLifecycleStateV2State) Type() string

+ type RunStatus struct

+ QueueDetails *QueueDetails

+ State RunLifecycleStateV2State

+ TerminationDetails *TerminationDetails

type RunTask

+ Status *RunStatus

+ type TerminationCodeCode string

+ const TerminationCodeCodeCanceled

+ const TerminationCodeCodeCloudFailure

+ const TerminationCodeCodeClusterError

+ const TerminationCodeCodeClusterRequestLimitExceeded

+ const TerminationCodeCodeDriverError

+ const TerminationCodeCodeFeatureDisabled

+ const TerminationCodeCodeInternalError

+ const TerminationCodeCodeInvalidClusterRequest

+ const TerminationCodeCodeInvalidRunConfiguration

+ const TerminationCodeCodeLibraryInstallationError

+ const TerminationCodeCodeMaxConcurrentRunsExceeded

+ const TerminationCodeCodeMaxJobQueueSizeExceeded

+ const TerminationCodeCodeMaxSparkContextsExceeded

+ const TerminationCodeCodeRepositoryCheckoutFailed

+ const TerminationCodeCodeResourceNotFound

+ const TerminationCodeCodeRunExecutionError

+ const TerminationCodeCodeSkipped

+ const TerminationCodeCodeStorageAccessError

+ const TerminationCodeCodeSuccess

+ const TerminationCodeCodeUnauthorizedError

+ const TerminationCodeCodeWorkspaceRunLimitExceeded

+ func (f *TerminationCodeCode) Set(v string) error

+ func (f *TerminationCodeCode) String() string

+ func (f *TerminationCodeCode) Type() string

+ type TerminationDetails struct

+ Code TerminationCodeCode

+ ForceSendFields []string

+ Message string

+ Type TerminationTypeType

+ func (s *TerminationDetails) UnmarshalJSON(b []byte) error

+ func (s TerminationDetails) MarshalJSON() ([]byte, error)

+ type TerminationTypeType string

+ const TerminationTypeTypeClientError

+ const TerminationTypeTypeCloudFailure

+ const TerminationTypeTypeInternalError

+ const TerminationTypeTypeSuccess

+ func (f *TerminationTypeType) Set(v string) error

+ func (f *TerminationTypeType) String() string

+ func (f *TerminationTypeType) Type() string

Aug 21, 2024

Changes in this version

type BaseRun

+ JobRunId int64

+ type EnforcePolicyComplianceForJobResponseJobClusterSettingsChange struct

+ Field string

+ ForceSendFields []string

+ NewValue string

+ PreviousValue string

+ func (s *EnforcePolicyComplianceForJobResponseJobClusterSettingsChange) UnmarshalJSON(b []byte) error

+ func (s EnforcePolicyComplianceForJobResponseJobClusterSettingsChange) MarshalJSON() ([]byte, error)

+ type EnforcePolicyComplianceRequest struct

+ ForceSendFields []string

+ JobId int64

+ ValidateOnly bool

+ func (s *EnforcePolicyComplianceRequest) UnmarshalJSON(b []byte) error

+ func (s EnforcePolicyComplianceRequest) MarshalJSON() ([]byte, error)

+ type EnforcePolicyComplianceResponse struct

+ ForceSendFields []string

+ HasChanges bool

+ JobClusterChanges []EnforcePolicyComplianceForJobResponseJobClusterSettingsChange

+ Settings *JobSettings

+ func (s *EnforcePolicyComplianceResponse) UnmarshalJSON(b []byte) error

+ func (s EnforcePolicyComplianceResponse) MarshalJSON() ([]byte, error)

+ type GetPolicyComplianceRequest struct

+ JobId int64

+ type GetPolicyComplianceResponse struct

+ ForceSendFields []string

+ IsCompliant bool

+ Violations map[string]string

+ func (s *GetPolicyComplianceResponse) UnmarshalJSON(b []byte) error

+ func (s GetPolicyComplianceResponse) MarshalJSON() ([]byte, error)

+ type JobCompliance struct

+ ForceSendFields []string

+ IsCompliant bool

+ JobId int64

+ Violations map[string]string

+ func (s *JobCompliance) UnmarshalJSON(b []byte) error

+ func (s JobCompliance) MarshalJSON() ([]byte, error)

+ type ListJobComplianceForPolicyResponse struct

+ ForceSendFields []string

+ Jobs []JobCompliance

+ NextPageToken string

+ PrevPageToken string

+ func (s *ListJobComplianceForPolicyResponse) UnmarshalJSON(b []byte) error

+ func (s ListJobComplianceForPolicyResponse) MarshalJSON() ([]byte, error)

+ type ListJobComplianceRequest struct

+ ForceSendFields []string

+ PageSize int

+ PageToken string

+ PolicyId string

+ func (s *ListJobComplianceRequest) UnmarshalJSON(b []byte) error

+ func (s ListJobComplianceRequest) MarshalJSON() ([]byte, error)

+ type PolicyComplianceForJobsAPI struct

+ func NewPolicyComplianceForJobs(client *client.DatabricksClient) *PolicyComplianceForJobsAPI

+ func (a *PolicyComplianceForJobsAPI) EnforceCompliance(ctx context.Context, request EnforcePolicyComplianceRequest) (*EnforcePolicyComplianceResponse, error)

+ func (a *PolicyComplianceForJobsAPI) GetCompliance(ctx context.Context, request GetPolicyComplianceRequest) (*GetPolicyComplianceResponse, error)

+ func (a *PolicyComplianceForJobsAPI) GetComplianceByJobId(ctx context.Context, jobId int64) (*GetPolicyComplianceResponse, error)

+ func (a *PolicyComplianceForJobsAPI) ListCompliance(ctx context.Context, request ListJobComplianceRequest) listing.Iterator[JobCompliance]

+ func (a *PolicyComplianceForJobsAPI) ListComplianceAll(ctx context.Context, request ListJobComplianceRequest) ([]JobCompliance, error)

+ type PolicyComplianceForJobsInterface interface

+ EnforceCompliance func(ctx context.Context, request EnforcePolicyComplianceRequest) (*EnforcePolicyComplianceResponse, error)

+ GetCompliance func(ctx context.Context, request GetPolicyComplianceRequest) (*GetPolicyComplianceResponse, error)

+ GetComplianceByJobId func(ctx context.Context, jobId int64) (*GetPolicyComplianceResponse, error)

+ ListCompliance func(ctx context.Context, request ListJobComplianceRequest) listing.Iterator[JobCompliance]

+ ListComplianceAll func(ctx context.Context, request ListJobComplianceRequest) ([]JobCompliance, error)

+ type PolicyComplianceForJobsService interface

+ EnforceCompliance func(ctx context.Context, request EnforcePolicyComplianceRequest) (*EnforcePolicyComplianceResponse, error)

+ GetCompliance func(ctx context.Context, request GetPolicyComplianceRequest) (*GetPolicyComplianceResponse, error)

+ ListCompliance func(ctx context.Context, request ListJobComplianceRequest) (*ListJobComplianceForPolicyResponse, error)

type Run

+ JobRunId int64

Aug 13, 2024

Changes in this version

type GetRunRequest

+ PageToken string

type Run

+ Iterations []RunTask

+ NextPageToken string

+ PrevPageToken string

Jun 24, 2024

Changes in this version

type JobEmailNotifications

+ OnStreamingBacklogExceeded []string

type JobsHealthMetric

+ const JobsHealthMetricStreamingBacklogBytes

+ const JobsHealthMetricStreamingBacklogFiles

+ const JobsHealthMetricStreamingBacklogRecords

+ const JobsHealthMetricStreamingBacklogSeconds

+ type PeriodicTriggerConfiguration struct

+ Interval int

+ Unit PeriodicTriggerConfigurationTimeUnit

+ type PeriodicTriggerConfigurationTimeUnit string

+ const PeriodicTriggerConfigurationTimeUnitDays

+ const PeriodicTriggerConfigurationTimeUnitHours

+ const PeriodicTriggerConfigurationTimeUnitTimeUnitUnspecified

+ const PeriodicTriggerConfigurationTimeUnitWeeks

+ func (f *PeriodicTriggerConfigurationTimeUnit) Set(v string) error

+ func (f *PeriodicTriggerConfigurationTimeUnit) String() string

+ func (f *PeriodicTriggerConfigurationTimeUnit) Type() string

type RunTask

+ EnvironmentKey string

type SubmitRun

+ Environments []JobEnvironment

type SubmitTask

+ DbtTask *DbtTask

+ EnvironmentKey string

type TaskEmailNotifications

+ OnStreamingBacklogExceeded []string

type TriggerSettings

+ Periodic *PeriodicTriggerConfiguration

type WebhookNotifications

+ OnStreamingBacklogExceeded []Webhook

Jun 3, 2024

Changes in this version

type ForEachTaskErrorMessageStats

+ TerminationCategory string

Apr 24, 2024

Changes in this version

type NotebookTask

+ ForceSendFields []string

+ WarehouseId string

+ func (s *NotebookTask) UnmarshalJSON(b []byte) error

+ func (s NotebookTask) MarshalJSON() ([]byte, error)

type SubmitRun

+ RunAs *JobRunAs

Apr 11, 2024

Changes in this version

type CreateJob

+ Environments []JobEnvironment

+ type JobEnvironment struct

+ EnvironmentKey string

+ Spec *compute.Environment

type JobSettings

+ Environments []JobEnvironment

+ type TableUpdateTriggerConfiguration struct

+ Condition Condition

+ ForceSendFields []string

+ MinTimeBetweenTriggersSeconds int

+ TableNames []string

+ WaitAfterLastChangeSeconds int

+ func (s *TableUpdateTriggerConfiguration) UnmarshalJSON(b []byte) error

+ func (s TableUpdateTriggerConfiguration) MarshalJSON() ([]byte, error)

type Task

+ EnvironmentKey string

Mar 28, 2024

Changes in this version

type BaseRun

+ Description string

+ QueueDuration int64

+ RepairHistory []RepairHistoryItem

type ClusterSpec

+ ComputeKey string

+ JobClusterKey string

+ type JobEditMode string

+ const JobEditModeEditable

+ const JobEditModeUiLocked

+ func (f *JobEditMode) Set(v string) error

+ func (f *JobEditMode) String() string

+ func (f *JobEditMode) Type() string

type ResolvedRunJobTaskValues

+ JobParameters map[string]string

type Run

+ Description string

+ QueueDuration int64

type RunJobTask

+ DbtCommands []string

+ JarParams []string

+ NotebookParams map[string]string

+ PipelineParams *PipelineParams

+ PythonNamedParams map[string]string

+ PythonParams []string

+ SparkSubmitParams []string

+ SqlParams map[string]string

type RunOutput

+ Info string

type RunTask

+ ComputeKey string

+ EmailNotifications *JobEmailNotifications

+ JobClusterKey string

+ NotificationSettings *TaskNotificationSettings

+ RunDuration int64

+ RunPageUrl string

+ TimeoutSeconds int

+ WebhookNotifications *WebhookNotifications

type SqlQueryOutput

+ EndpointId string

type SubmitRun

+ ConditionTask *ConditionTask

+ DbtTask *DbtTask

+ NotebookTask *NotebookTask

+ PipelineTask *PipelineTask

+ PythonWheelTask *PythonWheelTask

+ RunJobTask *RunJobTask

+ SparkJarTask *SparkJarTask

+ SparkPythonTask *SparkPythonTask

+ SparkSubmitTask *SparkSubmitTask

+ SqlTask *SqlTask

type SubmitTask

+ Description string

type Task

+ DisableAutoOptimization bool

type TaskEmailNotifications

+ ForceSendFields []string

+ NoAlertForSkippedRuns bool

+ func (s *TaskEmailNotifications) UnmarshalJSON(b []byte) error

+ func (s TaskEmailNotifications) MarshalJSON() ([]byte, error)

type TriggerSettings

+ TableUpdate *TableTriggerConfiguration

Mar 5, 2024

Changes in this version

+ type CancelAllRunsResponse struct

+ type CancelRunResponse struct

+ type DeleteResponse struct

+ type DeleteRunResponse struct

+ type ResetResponse struct

+ type UpdateResponse struct

Feb 14, 2024

Changes in this version

+ type Condition string

+ const ConditionAllUpdated

+ const ConditionAnyUpdated

+ func (f *Condition) Set(v string) error

+ func (f *Condition) String() string

+ func (f *Condition) Type() string

+ type TableTriggerConfiguration struct

+ Condition Condition

+ ForceSendFields []string

+ MinTimeBetweenTriggersSeconds int

+ TableNames []string

+ WaitAfterLastChangeSeconds int

+ func (s *TableTriggerConfiguration) UnmarshalJSON(b []byte) error

+ func (s TableTriggerConfiguration) MarshalJSON() ([]byte, error)

type TriggerSettings

+ Table *TableTriggerConfiguration

type TriggerType

+ const TriggerTypeTable

Feb 8, 2024

Changes in this version

type DbtTask

+ Source Source

+ type ForEachStats struct

+ ErrorMessageStats *ForEachTaskErrorMessageStats

+ TaskRunStats *ForEachTaskTaskRunStats

+ type ForEachTask struct

+ Concurrency int

+ ForceSendFields []string

+ Inputs string

+ Task Task

+ func (s *ForEachTask) UnmarshalJSON(b []byte) error

+ func (s ForEachTask) MarshalJSON() ([]byte, error)

+ type ForEachTaskErrorMessageStats struct

+ Count string

+ ErrorMessage string

+ ForceSendFields []string

+ func (s *ForEachTaskErrorMessageStats) UnmarshalJSON(b []byte) error

+ func (s ForEachTaskErrorMessageStats) MarshalJSON() ([]byte, error)

+ type ForEachTaskTaskRunStats struct

+ ActiveIterations int

+ CompletedIterations int

+ FailedIterations int

+ ForceSendFields []string

+ ScheduledIterations int

+ SucceededIterations int

+ TotalIterations int

+ func (s *ForEachTaskTaskRunStats) UnmarshalJSON(b []byte) error

+ func (s ForEachTaskTaskRunStats) MarshalJSON() ([]byte, error)

+ type RunForEachTask struct

+ Concurrency int

+ ForceSendFields []string

+ Inputs string

+ Stats *ForEachStats

+ Task *Task

+ func (s *RunForEachTask) UnmarshalJSON(b []byte) error

+ func (s RunForEachTask) MarshalJSON() ([]byte, error)

type RunTask

+ ForEachTask *RunForEachTask

type SqlTaskFile

+ Source Source

type SubmitTask

+ ForEachTask *ForEachTask

type Task

+ ForEachTask *ForEachTask

Jan 16, 2024

Changes in this version

type WaitGetRunJobTerminatedOrSkipped

+ Poll func(time.Duration, func(*Run)) (*Run, error)

Jan 10, 2024

Changes in this version

+ type JobsInterface interface

+ BaseJobSettingsNameToJobIdMap func(ctx context.Context, request ListJobsRequest) (map[string]int64, error)

+ CancelAllRuns func(ctx context.Context, request CancelAllRuns) error

+ CancelRun func(ctx context.Context, cancelRun CancelRun) (*WaitGetRunJobTerminatedOrSkipped[any], error)

+ CancelRunAndWait func(ctx context.Context, cancelRun CancelRun, options ...retries.Option[Run]) (*Run, error)

+ CancelRunByRunId func(ctx context.Context, runId int64) error

+ CancelRunByRunIdAndWait func(ctx context.Context, runId int64, options ...retries.Option[Run]) (*Run, error)

+ Create func(ctx context.Context, request CreateJob) (*CreateResponse, error)

+ Delete func(ctx context.Context, request DeleteJob) error

+ DeleteByJobId func(ctx context.Context, jobId int64) error

+ DeleteRun func(ctx context.Context, request DeleteRun) error

+ DeleteRunByRunId func(ctx context.Context, runId int64) error

+ ExportRun func(ctx context.Context, request ExportRunRequest) (*ExportRunOutput, error)

+ Get func(ctx context.Context, request GetJobRequest) (*Job, error)

+ GetByJobId func(ctx context.Context, jobId int64) (*Job, error)

+ GetBySettingsName func(ctx context.Context, name string) (*BaseJob, error)

+ GetPermissionLevels func(ctx context.Context, request GetJobPermissionLevelsRequest) (*GetJobPermissionLevelsResponse, error)

+ GetPermissionLevelsByJobId func(ctx context.Context, jobId string) (*GetJobPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetJobPermissionsRequest) (*JobPermissions, error)

+ GetPermissionsByJobId func(ctx context.Context, jobId string) (*JobPermissions, error)

+ GetRun func(ctx context.Context, request GetRunRequest) (*Run, error)

+ GetRunOutput func(ctx context.Context, request GetRunOutputRequest) (*RunOutput, error)

+ GetRunOutputByRunId func(ctx context.Context, runId int64) (*RunOutput, error)

+ Impl func() JobsService

+ List func(ctx context.Context, request ListJobsRequest) *listing.PaginatingIterator[ListJobsRequest, *ListJobsResponse, BaseJob]

+ ListAll func(ctx context.Context, request ListJobsRequest) ([]BaseJob, error)

+ ListRuns func(ctx context.Context, request ListRunsRequest) *listing.PaginatingIterator[ListRunsRequest, *ListRunsResponse, BaseRun]

+ ListRunsAll func(ctx context.Context, request ListRunsRequest) ([]BaseRun, error)

+ RepairRun func(ctx context.Context, repairRun RepairRun) (*WaitGetRunJobTerminatedOrSkipped[RepairRunResponse], error)

+ RepairRunAndWait func(ctx context.Context, repairRun RepairRun, options ...retries.Option[Run]) (*Run, error)

+ Reset func(ctx context.Context, request ResetJob) error

+ RunNow func(ctx context.Context, runNow RunNow) (*WaitGetRunJobTerminatedOrSkipped[RunNowResponse], error)

+ RunNowAndWait func(ctx context.Context, runNow RunNow, options ...retries.Option[Run]) (*Run, error)

+ SetPermissions func(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

+ Submit func(ctx context.Context, submitRun SubmitRun) (*WaitGetRunJobTerminatedOrSkipped[SubmitRunResponse], error)

+ SubmitAndWait func(ctx context.Context, submitRun SubmitRun, options ...retries.Option[Run]) (*Run, error)

+ Update func(ctx context.Context, request UpdateJob) error

+ UpdatePermissions func(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

+ WaitGetRunJobTerminatedOrSkipped func(ctx context.Context, runId int64, timeout time.Duration, callback func(*Run)) (*Run, error)

+ WithImpl func(impl JobsService) JobsInterface

Dec 12, 2023

Changes in this version

type SubmitTask

+ RunIf RunIf

+ RunJobTask *RunJobTask

Nov 29, 2023

Changes in this version

type CreateJob

+ Description string

type JobSettings

+ Description string

Nov 10, 2023

Changes in this version

type CreateJob

+ EditMode CreateJobEditMode

+ type CreateJobEditMode string

+ const CreateJobEditModeEditable

+ const CreateJobEditModeUiLocked

+ func (f *CreateJobEditMode) Set(v string) error

+ func (f *CreateJobEditMode) String() string

+ func (f *CreateJobEditMode) Type() string

type GetRunRequest

+ IncludeResolvedValues bool

type JobSettings

+ EditMode JobSettingsEditMode

+ type JobSettingsEditMode string

+ const JobSettingsEditModeEditable

+ const JobSettingsEditModeUiLocked

+ func (f *JobSettingsEditMode) Set(v string) error

+ func (f *JobSettingsEditMode) String() string

+ func (f *JobSettingsEditMode) Type() string

Oct 24, 2023

Changes in this version

type JobsAPI

+ func (a *JobsAPI) List(ctx context.Context, request ListJobsRequest) *listing.PaginatingIterator[ListJobsRequest, *ListJobsResponse, BaseJob]

+ func (a *JobsAPI) ListRuns(ctx context.Context, request ListRunsRequest) *listing.PaginatingIterator[ListRunsRequest, *ListRunsResponse, BaseRun]

type SubmitTask

+ WebhookNotifications *WebhookNotifications

Oct 12, 2023

Changes in this version

type BaseJob

+ ForceSendFields []string

+ func (s *BaseJob) UnmarshalJSON(b []byte) error

+ func (s BaseJob) MarshalJSON() ([]byte, error)

type BaseRun

+ ForceSendFields []string

+ func (s *BaseRun) UnmarshalJSON(b []byte) error

+ func (s BaseRun) MarshalJSON() ([]byte, error)

type CancelAllRuns

+ ForceSendFields []string

+ func (s *CancelAllRuns) UnmarshalJSON(b []byte) error

+ func (s CancelAllRuns) MarshalJSON() ([]byte, error)

type ClusterInstance

+ ForceSendFields []string

+ func (s *ClusterInstance) UnmarshalJSON(b []byte) error

+ func (s ClusterInstance) MarshalJSON() ([]byte, error)

type ClusterSpec

+ ForceSendFields []string

+ func (s *ClusterSpec) UnmarshalJSON(b []byte) error

+ func (s ClusterSpec) MarshalJSON() ([]byte, error)

type ConditionTask

+ ForceSendFields []string

+ func (s *ConditionTask) UnmarshalJSON(b []byte) error

+ func (s ConditionTask) MarshalJSON() ([]byte, error)

type CreateJob

+ Deployment *JobDeployment

+ ForceSendFields []string

+ UiState CreateJobUiState

+ func (s *CreateJob) UnmarshalJSON(b []byte) error

+ func (s CreateJob) MarshalJSON() ([]byte, error)

+ type CreateJobUiState string

+ const CreateJobUiStateEditable

+ const CreateJobUiStateLocked

+ func (f *CreateJobUiState) Set(v string) error

+ func (f *CreateJobUiState) String() string

+ func (f *CreateJobUiState) Type() string

type CreateResponse

+ ForceSendFields []string

+ func (s *CreateResponse) UnmarshalJSON(b []byte) error

+ func (s CreateResponse) MarshalJSON() ([]byte, error)

type DbtOutput

+ ForceSendFields []string

+ func (s *DbtOutput) UnmarshalJSON(b []byte) error

+ func (s DbtOutput) MarshalJSON() ([]byte, error)

type DbtTask

+ ForceSendFields []string

+ func (s *DbtTask) UnmarshalJSON(b []byte) error

+ func (s DbtTask) MarshalJSON() ([]byte, error)

type FileArrivalTriggerConfiguration

+ ForceSendFields []string

+ func (s *FileArrivalTriggerConfiguration) UnmarshalJSON(b []byte) error

+ func (s FileArrivalTriggerConfiguration) MarshalJSON() ([]byte, error)

type GetRunRequest

+ ForceSendFields []string

+ func (s *GetRunRequest) UnmarshalJSON(b []byte) error

+ func (s GetRunRequest) MarshalJSON() ([]byte, error)

type GitSnapshot

+ ForceSendFields []string

+ func (s *GitSnapshot) UnmarshalJSON(b []byte) error

+ func (s GitSnapshot) MarshalJSON() ([]byte, error)

type GitSource

+ ForceSendFields []string

+ func (s *GitSource) UnmarshalJSON(b []byte) error

+ func (s GitSource) MarshalJSON() ([]byte, error)

type Job

+ ForceSendFields []string

+ func (s *Job) UnmarshalJSON(b []byte) error

+ func (s Job) MarshalJSON() ([]byte, error)

type JobAccessControlRequest

+ ForceSendFields []string

+ func (s *JobAccessControlRequest) UnmarshalJSON(b []byte) error

+ func (s JobAccessControlRequest) MarshalJSON() ([]byte, error)

type JobAccessControlResponse

+ ForceSendFields []string

+ func (s *JobAccessControlResponse) UnmarshalJSON(b []byte) error

+ func (s JobAccessControlResponse) MarshalJSON() ([]byte, error)

+ type JobDeployment struct

+ ForceSendFields []string

+ Kind JobDeploymentKind

+ MetadataFilePath string

+ func (s *JobDeployment) UnmarshalJSON(b []byte) error

+ func (s JobDeployment) MarshalJSON() ([]byte, error)

+ type JobDeploymentKind string

+ const JobDeploymentKindBundle

+ func (f *JobDeploymentKind) Set(v string) error

+ func (f *JobDeploymentKind) String() string

+ func (f *JobDeploymentKind) Type() string

type JobEmailNotifications

+ ForceSendFields []string

+ func (s *JobEmailNotifications) UnmarshalJSON(b []byte) error

+ func (s JobEmailNotifications) MarshalJSON() ([]byte, error)

type JobNotificationSettings

+ ForceSendFields []string

+ func (s *JobNotificationSettings) UnmarshalJSON(b []byte) error

+ func (s JobNotificationSettings) MarshalJSON() ([]byte, error)

type JobParameter

+ ForceSendFields []string

+ func (s *JobParameter) UnmarshalJSON(b []byte) error

+ func (s JobParameter) MarshalJSON() ([]byte, error)

type JobPermission

+ ForceSendFields []string

+ func (s *JobPermission) UnmarshalJSON(b []byte) error

+ func (s JobPermission) MarshalJSON() ([]byte, error)

type JobPermissions

+ ForceSendFields []string

+ func (s *JobPermissions) UnmarshalJSON(b []byte) error

+ func (s JobPermissions) MarshalJSON() ([]byte, error)

type JobPermissionsDescription

+ ForceSendFields []string

+ func (s *JobPermissionsDescription) UnmarshalJSON(b []byte) error

+ func (s JobPermissionsDescription) MarshalJSON() ([]byte, error)

type JobRunAs

+ ForceSendFields []string

+ func (s *JobRunAs) UnmarshalJSON(b []byte) error

+ func (s JobRunAs) MarshalJSON() ([]byte, error)

type JobSettings

+ Deployment *JobDeployment

+ ForceSendFields []string

+ UiState JobSettingsUiState

+ func (s *JobSettings) UnmarshalJSON(b []byte) error

+ func (s JobSettings) MarshalJSON() ([]byte, error)

+ type JobSettingsUiState string

+ const JobSettingsUiStateEditable

+ const JobSettingsUiStateLocked

+ func (f *JobSettingsUiState) Set(v string) error

+ func (f *JobSettingsUiState) String() string

+ func (f *JobSettingsUiState) Type() string

type JobsHealthRule

+ ForceSendFields []string

+ func (s *JobsHealthRule) UnmarshalJSON(b []byte) error

+ func (s JobsHealthRule) MarshalJSON() ([]byte, error)

type ListJobsRequest

+ ForceSendFields []string

+ func (s *ListJobsRequest) UnmarshalJSON(b []byte) error

+ func (s ListJobsRequest) MarshalJSON() ([]byte, error)

type ListJobsResponse

+ ForceSendFields []string

+ func (s *ListJobsResponse) UnmarshalJSON(b []byte) error

+ func (s ListJobsResponse) MarshalJSON() ([]byte, error)

type ListRunsRequest

+ ForceSendFields []string

+ func (s *ListRunsRequest) UnmarshalJSON(b []byte) error

+ func (s ListRunsRequest) MarshalJSON() ([]byte, error)

type ListRunsResponse

+ ForceSendFields []string

+ func (s *ListRunsResponse) UnmarshalJSON(b []byte) error

+ func (s ListRunsResponse) MarshalJSON() ([]byte, error)

type NotebookOutput

+ ForceSendFields []string

+ func (s *NotebookOutput) UnmarshalJSON(b []byte) error

+ func (s NotebookOutput) MarshalJSON() ([]byte, error)

type PipelineParams

+ ForceSendFields []string

+ func (s *PipelineParams) UnmarshalJSON(b []byte) error

+ func (s PipelineParams) MarshalJSON() ([]byte, error)

type PipelineTask

+ ForceSendFields []string

+ func (s *PipelineTask) UnmarshalJSON(b []byte) error

+ func (s PipelineTask) MarshalJSON() ([]byte, error)

type PythonWheelTask

+ ForceSendFields []string

+ func (s *PythonWheelTask) UnmarshalJSON(b []byte) error

+ func (s PythonWheelTask) MarshalJSON() ([]byte, error)

type RepairHistoryItem

+ ForceSendFields []string

+ func (s *RepairHistoryItem) UnmarshalJSON(b []byte) error

+ func (s RepairHistoryItem) MarshalJSON() ([]byte, error)

type RepairRun

+ ForceSendFields []string

+ func (s *RepairRun) UnmarshalJSON(b []byte) error

+ func (s RepairRun) MarshalJSON() ([]byte, error)

type RepairRunResponse

+ ForceSendFields []string

+ func (s *RepairRunResponse) UnmarshalJSON(b []byte) error

+ func (s RepairRunResponse) MarshalJSON() ([]byte, error)

type ResolvedConditionTaskValues

+ ForceSendFields []string

+ func (s *ResolvedConditionTaskValues) UnmarshalJSON(b []byte) error

+ func (s ResolvedConditionTaskValues) MarshalJSON() ([]byte, error)

type Run

+ ForceSendFields []string

+ func (s *Run) UnmarshalJSON(b []byte) error

+ func (s Run) MarshalJSON() ([]byte, error)

type RunConditionTask

+ ForceSendFields []string

+ func (s *RunConditionTask) UnmarshalJSON(b []byte) error

+ func (s RunConditionTask) MarshalJSON() ([]byte, error)

type RunJobOutput

+ ForceSendFields []string

+ func (s *RunJobOutput) UnmarshalJSON(b []byte) error

+ func (s RunJobOutput) MarshalJSON() ([]byte, error)

type RunNow

+ ForceSendFields []string

+ func (s *RunNow) UnmarshalJSON(b []byte) error

+ func (s RunNow) MarshalJSON() ([]byte, error)

type RunNowResponse

+ ForceSendFields []string

+ func (s *RunNowResponse) UnmarshalJSON(b []byte) error

+ func (s RunNowResponse) MarshalJSON() ([]byte, error)

type RunOutput

+ ForceSendFields []string

+ func (s *RunOutput) UnmarshalJSON(b []byte) error

+ func (s RunOutput) MarshalJSON() ([]byte, error)

type RunState

+ ForceSendFields []string

+ func (s *RunState) UnmarshalJSON(b []byte) error

+ func (s RunState) MarshalJSON() ([]byte, error)

type RunTask

+ ForceSendFields []string

+ func (s *RunTask) UnmarshalJSON(b []byte) error

+ func (s RunTask) MarshalJSON() ([]byte, error)

type SparkJarTask

+ ForceSendFields []string

+ func (s *SparkJarTask) UnmarshalJSON(b []byte) error

+ func (s SparkJarTask) MarshalJSON() ([]byte, error)

type SqlAlertOutput

+ ForceSendFields []string

+ func (s *SqlAlertOutput) UnmarshalJSON(b []byte) error

+ func (s SqlAlertOutput) MarshalJSON() ([]byte, error)

type SqlDashboardOutput

+ ForceSendFields []string

+ func (s *SqlDashboardOutput) UnmarshalJSON(b []byte) error

+ func (s SqlDashboardOutput) MarshalJSON() ([]byte, error)

type SqlDashboardWidgetOutput

+ ForceSendFields []string

+ func (s *SqlDashboardWidgetOutput) UnmarshalJSON(b []byte) error

+ func (s SqlDashboardWidgetOutput) MarshalJSON() ([]byte, error)

type SqlOutputError

+ ForceSendFields []string

+ func (s *SqlOutputError) UnmarshalJSON(b []byte) error

+ func (s SqlOutputError) MarshalJSON() ([]byte, error)

type SqlQueryOutput

+ ForceSendFields []string

+ func (s *SqlQueryOutput) UnmarshalJSON(b []byte) error

+ func (s SqlQueryOutput) MarshalJSON() ([]byte, error)

type SqlStatementOutput

+ ForceSendFields []string

+ func (s *SqlStatementOutput) UnmarshalJSON(b []byte) error

+ func (s SqlStatementOutput) MarshalJSON() ([]byte, error)

type SqlTaskAlert

+ ForceSendFields []string

+ func (s *SqlTaskAlert) UnmarshalJSON(b []byte) error

+ func (s SqlTaskAlert) MarshalJSON() ([]byte, error)

type SqlTaskDashboard

+ ForceSendFields []string

+ func (s *SqlTaskDashboard) UnmarshalJSON(b []byte) error

+ func (s SqlTaskDashboard) MarshalJSON() ([]byte, error)

type SqlTaskSubscription

+ ForceSendFields []string

+ func (s *SqlTaskSubscription) UnmarshalJSON(b []byte) error

+ func (s SqlTaskSubscription) MarshalJSON() ([]byte, error)

type SubmitRun

+ ForceSendFields []string

+ func (s *SubmitRun) UnmarshalJSON(b []byte) error

+ func (s SubmitRun) MarshalJSON() ([]byte, error)

type SubmitRunResponse

+ ForceSendFields []string

+ func (s *SubmitRunResponse) UnmarshalJSON(b []byte) error

+ func (s SubmitRunResponse) MarshalJSON() ([]byte, error)

type SubmitTask

+ ForceSendFields []string

+ func (s *SubmitTask) UnmarshalJSON(b []byte) error

+ func (s SubmitTask) MarshalJSON() ([]byte, error)

type Task

+ ForceSendFields []string

+ WebhookNotifications *WebhookNotifications

+ func (s *Task) UnmarshalJSON(b []byte) error

+ func (s Task) MarshalJSON() ([]byte, error)

type TaskDependency

+ ForceSendFields []string

+ func (s *TaskDependency) UnmarshalJSON(b []byte) error

+ func (s TaskDependency) MarshalJSON() ([]byte, error)

type TaskNotificationSettings

+ ForceSendFields []string

+ func (s *TaskNotificationSettings) UnmarshalJSON(b []byte) error

+ func (s TaskNotificationSettings) MarshalJSON() ([]byte, error)

type TriggerEvaluation

+ ForceSendFields []string

+ func (s *TriggerEvaluation) UnmarshalJSON(b []byte) error

+ func (s TriggerEvaluation) MarshalJSON() ([]byte, error)

type TriggerInfo

+ ForceSendFields []string

+ func (s *TriggerInfo) UnmarshalJSON(b []byte) error

+ func (s TriggerInfo) MarshalJSON() ([]byte, error)

type ViewItem

+ ForceSendFields []string

+ func (s *ViewItem) UnmarshalJSON(b []byte) error

+ func (s ViewItem) MarshalJSON() ([]byte, error)

type Webhook

+ ForceSendFields []string

+ func (s *Webhook) UnmarshalJSON(b []byte) error

+ func (s Webhook) MarshalJSON() ([]byte, error)

type WebhookNotificationsOnDurationWarningThresholdExceededItem

+ ForceSendFields []string

+ func (s *WebhookNotificationsOnDurationWarningThresholdExceededItem) UnmarshalJSON(b []byte) error

+ func (s WebhookNotificationsOnDurationWarningThresholdExceededItem) MarshalJSON() ([]byte, error)

Sep 27, 2023

Changes in this version

type CancelAllRuns

+ AllQueuedRuns bool

type CreateJob

+ Queue *QueueSettings

type JobSettings

+ Queue *QueueSettings

+ type QueueSettings struct

+ Enabled bool

type RepairRun

+ JobParameters map[string]string

type RunLifeCycleState

+ const RunLifeCycleStateQueued

type RunNow

+ Queue *QueueSettings

type RunParameters

+ JobParameters map[string]string

type RunState

+ QueueReason string

type RunTask

+ QueueDuration int64

type SubmitRun

+ Queue *QueueSettings

Sep 4, 2023

Changes in this version

type JobsAPI

+ func (a *JobsAPI) GetPermissionLevels(ctx context.Context, request GetJobPermissionLevelsRequest) (*GetJobPermissionLevelsResponse, error)

+ func (a *JobsAPI) GetPermissionLevelsByJobId(ctx context.Context, jobId string) (*GetJobPermissionLevelsResponse, error)

+ func (a *JobsAPI) GetPermissions(ctx context.Context, request GetJobPermissionsRequest) (*JobPermissions, error)

+ func (a *JobsAPI) GetPermissionsByJobId(ctx context.Context, jobId string) (*JobPermissions, error)

+ func (a *JobsAPI) SetPermissions(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

+ func (a *JobsAPI) UpdatePermissions(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

type JobsService

+ GetPermissionLevels func(ctx context.Context, request GetJobPermissionLevelsRequest) (*GetJobPermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetJobPermissionsRequest) (*JobPermissions, error)

+ SetPermissions func(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

+ UpdatePermissions func(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

Aug 7, 2023

Changes in this version

+ type GetJobPermissionLevelsRequest struct

+ JobId string

+ type GetJobPermissionLevelsResponse struct

+ PermissionLevels []JobPermissionsDescription

+ type GetJobPermissionsRequest struct

+ JobId string

+ type JobAccessControlRequest struct

+ GroupName string

+ PermissionLevel JobPermissionLevel

+ ServicePrincipalName string

+ UserName string

+ type JobAccessControlResponse struct

+ AllPermissions []JobPermission

+ DisplayName string

+ GroupName string

+ ServicePrincipalName string

+ UserName string

+ type JobPermission struct

+ Inherited bool

+ InheritedFromObject []string

+ PermissionLevel JobPermissionLevel

+ type JobPermissionLevel string

+ const JobPermissionLevelCanManage

+ const JobPermissionLevelCanManageRun

+ const JobPermissionLevelCanView

+ const JobPermissionLevelIsOwner

+ func (f *JobPermissionLevel) Set(v string) error

+ func (f *JobPermissionLevel) String() string

+ func (f *JobPermissionLevel) Type() string

+ type JobPermissions struct

+ AccessControlList []JobAccessControlResponse

+ ObjectId string

+ ObjectType string

+ type JobPermissionsDescription struct

+ Description string

+ PermissionLevel JobPermissionLevel

+ type JobPermissionsRequest struct

+ AccessControlList []JobAccessControlRequest

+ JobId string

type JobsAPI

+ func (a *JobsAPI) GetJobPermissionLevels(ctx context.Context, request GetJobPermissionLevelsRequest) (*GetJobPermissionLevelsResponse, error)

+ func (a *JobsAPI) GetJobPermissionLevelsByJobId(ctx context.Context, jobId string) (*GetJobPermissionLevelsResponse, error)

+ func (a *JobsAPI) GetJobPermissions(ctx context.Context, request GetJobPermissionsRequest) (*JobPermissions, error)

+ func (a *JobsAPI) GetJobPermissionsByJobId(ctx context.Context, jobId string) (*JobPermissions, error)

+ func (a *JobsAPI) SetJobPermissions(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

+ func (a *JobsAPI) UpdateJobPermissions(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

type JobsService

+ GetJobPermissionLevels func(ctx context.Context, request GetJobPermissionLevelsRequest) (*GetJobPermissionLevelsResponse, error)

+ GetJobPermissions func(ctx context.Context, request GetJobPermissionsRequest) (*JobPermissions, error)

+ SetJobPermissions func(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

+ UpdateJobPermissions func(ctx context.Context, request JobPermissionsRequest) (*JobPermissions, error)

Jul 18, 2023

Changes in this version

type BaseRun

+ TriggerInfo *TriggerInfo

type CreateJob

+ Health *JobsHealthRules

type GitProvider

+ const GitProviderAwsCodeCommit

+ const GitProviderAzureDevOpsServices

+ const GitProviderBitbucketCloud

+ const GitProviderBitbucketServer

+ const GitProviderGitHub

+ const GitProviderGitHubEnterprise

+ const GitProviderGitLab

+ const GitProviderGitLabEnterpriseEdition

type GitSource

+ JobSource *JobSource

type JobEmailNotifications

+ OnDurationWarningThresholdExceeded []string

type JobSettings

+ Health *JobsHealthRules

+ type JobSource struct

+ DirtyState JobSourceDirtyState

+ ImportFromGitBranch string

+ JobConfigPath string

+ type JobSourceDirtyState string

+ const JobSourceDirtyStateDisconnected

+ const JobSourceDirtyStateNotSynced

+ func (f *JobSourceDirtyState) Set(v string) error

+ func (f *JobSourceDirtyState) String() string

+ func (f *JobSourceDirtyState) Type() string

+ type JobsHealthMetric string

+ const JobsHealthMetricRunDurationSeconds

+ func (f *JobsHealthMetric) Set(v string) error

+ func (f *JobsHealthMetric) String() string

+ func (f *JobsHealthMetric) Type() string

+ type JobsHealthOperator string

+ const JobsHealthOperatorGreaterThan

+ func (f *JobsHealthOperator) Set(v string) error

+ func (f *JobsHealthOperator) String() string

+ func (f *JobsHealthOperator) Type() string

+ type JobsHealthRule struct

+ Metric JobsHealthMetric

+ Op JobsHealthOperator

+ Value int

+ type JobsHealthRules struct

+ Rules []JobsHealthRule

type Run

+ TriggerInfo *TriggerInfo

+ type RunJobOutput struct

+ RunId int

+ type RunJobTask struct

+ JobId int

+ JobParameters any

type RunOutput

+ RunJobOutput *RunJobOutput

type RunTask

+ RunJobTask *RunJobTask

type SubmitRun

+ EmailNotifications *JobEmailNotifications

+ Health *JobsHealthRules

type SubmitTask

+ EmailNotifications *JobEmailNotifications

+ Health *JobsHealthRules

+ NotificationSettings *TaskNotificationSettings

type Task

+ Health *JobsHealthRules

+ RunJobTask *RunJobTask

type TaskEmailNotifications

+ OnDurationWarningThresholdExceeded []string

+ type TriggerInfo struct

+ RunId int

type TriggerType

+ const TriggerTypeRunJobTask

type WebhookNotifications

+ OnDurationWarningThresholdExceeded []WebhookNotificationsOnDurationWarningThresholdExceededItem

+ type WebhookNotificationsOnDurationWarningThresholdExceededItem struct

+ Id string

Jun 28, 2023

Changes in this version

type BaseRun

+ JobParameters []JobParameter

type CreateJob

+ Parameters []JobParameterDefinition

type FileArrivalTriggerConfiguration

+ MinTimeBetweenTriggersSeconds int

+ type JobParameter struct

+ Default string

+ Name string

+ Value string

+ type JobParameterDefinition struct

+ Default string

+ Name string

type JobSettings

+ Parameters []JobParameterDefinition

+ type ParamPairs map[string]string

type RepairRun

+ RerunDependentTasks bool

+ type ResolvedConditionTaskValues struct

+ Left string

+ Right string

+ type ResolvedDbtTaskValues struct

+ Commands []string

+ type ResolvedNotebookTaskValues struct

+ BaseParameters map[string]string

+ type ResolvedParamPairValues struct

+ Parameters map[string]string

+ type ResolvedPythonWheelTaskValues struct

+ NamedParameters map[string]string

+ Parameters []string

+ type ResolvedRunJobTaskValues struct

+ NamedParameters map[string]string

+ Parameters map[string]string

+ type ResolvedStringParamsValues struct

+ Parameters []string

+ type ResolvedValues struct

+ ConditionTask *ResolvedConditionTaskValues

+ DbtTask *ResolvedDbtTaskValues

+ NotebookTask *ResolvedNotebookTaskValues

+ PythonWheelTask *ResolvedPythonWheelTaskValues

+ RunJobTask *ResolvedRunJobTaskValues

+ SimulationTask *ResolvedParamPairValues

+ SparkJarTask *ResolvedStringParamsValues

+ SparkPythonTask *ResolvedStringParamsValues

+ SparkSubmitTask *ResolvedStringParamsValues

+ SqlTask *ResolvedParamPairValues

type Run

+ JobParameters []JobParameter

+ type RunIf string

+ const RunIfAllDone

+ const RunIfAllFailed

+ const RunIfAllSuccess

+ const RunIfAtLeastOneFailed

+ const RunIfAtLeastOneSuccess

+ const RunIfNoneFailed

+ func (f *RunIf) Set(v string) error

+ func (f *RunIf) String() string

+ func (f *RunIf) Type() string

type RunNow

+ JobParameters []map[string]string

type RunResultState

+ const RunResultStateExcluded

+ const RunResultStateMaximumConcurrentRunsReached

+ const RunResultStateSuccessWithFailures

+ const RunResultStateUpstreamCanceled

+ const RunResultStateUpstreamFailed

type RunTask

+ ResolvedValues *ResolvedValues

+ RunIf RunIf

type Task

+ RunIf RunIf

Jun 28, 2023

Changes in this version

+ type ConditionTask struct

+ Left string

+ Op ConditionTaskOp

+ Right string

+ type ConditionTaskOp string

+ const ConditionTaskOpEqualTo

+ const ConditionTaskOpGreaterThan

+ const ConditionTaskOpGreaterThanOrEqual

+ const ConditionTaskOpLessThan

+ const ConditionTaskOpLessThanOrEqual

+ const ConditionTaskOpNotEqual

+ func (f *ConditionTaskOp) Set(v string) error

+ func (f *ConditionTaskOp) String() string

+ func (f *ConditionTaskOp) Type() string

type CreateJob

+ Compute []JobCompute

+ type FileArrivalTriggerConfiguration struct

+ MinTimeBetweenTriggerSeconds int

+ Url string

+ WaitAfterLastChangeSeconds int

+ type Format string

+ const FormatMultiTask

+ const FormatSingleTask

+ func (f *Format) Set(v string) error

+ func (f *Format) String() string

+ func (f *Format) Type() string

+ type GitProvider string

+ const GitProviderAwscodecommit

+ const GitProviderAzuredevopsservices

+ const GitProviderBitbucketcloud

+ const GitProviderBitbucketserver

+ const GitProviderGithub

+ const GitProviderGithubenterprise

+ const GitProviderGitlab

+ const GitProviderGitlabenterpriseedition

+ func (f *GitProvider) Set(v string) error

+ func (f *GitProvider) String() string

+ func (f *GitProvider) Type() string

+ type JobCompute struct

+ ComputeKey string

+ Spec compute.ComputeSpec

type JobSettings

+ Compute []JobCompute

+ type PauseStatus string

+ const PauseStatusPaused

+ const PauseStatusUnpaused

+ func (f *PauseStatus) Set(v string) error

+ func (f *PauseStatus) String() string

+ func (f *PauseStatus) Type() string

+ type RunConditionTask struct

+ Left string

+ Op RunConditionTaskOp

+ Outcome string

+ Right string

+ type RunConditionTaskOp string

+ const RunConditionTaskOpEqualTo

+ const RunConditionTaskOpGreaterThan

+ const RunConditionTaskOpGreaterThanOrEqual

+ const RunConditionTaskOpLessThan

+ const RunConditionTaskOpLessThanOrEqual

+ const RunConditionTaskOpNotEqual

+ func (f *RunConditionTaskOp) Set(v string) error

+ func (f *RunConditionTaskOp) String() string

+ func (f *RunConditionTaskOp) Type() string

type RunOutput

+ ConditionTask any

type RunTask

+ ConditionTask *RunConditionTask

+ type Source string

+ const SourceGit

+ const SourceWorkspace

+ func (f *Source) Set(v string) error

+ func (f *Source) String() string

+ func (f *Source) Type() string

+ type SubmitTask struct

+ ConditionTask *ConditionTask

+ DependsOn []TaskDependency

+ ExistingClusterId string

+ Libraries []compute.Library

+ NewCluster *compute.ClusterSpec

+ NotebookTask *NotebookTask

+ PipelineTask *PipelineTask

+ PythonWheelTask *PythonWheelTask

+ SparkJarTask *SparkJarTask

+ SparkPythonTask *SparkPythonTask

+ SparkSubmitTask *SparkSubmitTask

+ SqlTask *SqlTask

+ TaskKey string

+ TimeoutSeconds int

+ type Task struct

+ ComputeKey string

+ ConditionTask *ConditionTask

+ DbtTask *DbtTask

+ DependsOn []TaskDependency

+ Description string

+ EmailNotifications *TaskEmailNotifications

+ ExistingClusterId string

+ JobClusterKey string

+ Libraries []compute.Library

+ MaxRetries int

+ MinRetryIntervalMillis int

+ NewCluster *compute.ClusterSpec

+ NotebookTask *NotebookTask

+ NotificationSettings *TaskNotificationSettings

+ PipelineTask *PipelineTask

+ PythonWheelTask *PythonWheelTask

+ RetryOnTimeout bool

+ SparkJarTask *SparkJarTask

+ SparkPythonTask *SparkPythonTask

+ SparkSubmitTask *SparkSubmitTask

+ SqlTask *SqlTask

+ TaskKey string

+ TimeoutSeconds int

+ type TaskDependency struct

+ Outcome string

+ TaskKey string

+ type Webhook struct

+ Id string

+ type WebhookNotifications struct

+ OnFailure []Webhook

+ OnStart []Webhook

+ OnSuccess []Webhook

Jun 15, 2023

Changes in this version

type CreateJob

+ RunAs *JobRunAs

+ type JobRunAs struct

+ ServicePrincipalName string

+ UserName string

type JobSettings

+ RunAs *JobRunAs

type JobsAPI

+ func (a *JobsAPI) WaitGetRunJobTerminatedOrSkipped(ctx context.Context, runId int64, timeout time.Duration, callback func(*Run)) (*Run, error)

type ListJobsRequest

+ PageToken string

type ListJobsResponse

+ NextPageToken string

+ PrevPageToken string

type ListRunsRequest

+ PageToken string

type ListRunsResponse

+ NextPageToken string

+ PrevPageToken string

+ type WaitGetRunJobTerminatedOrSkipped struct

+ Response *R

+ RunId int64

+ func (w *WaitGetRunJobTerminatedOrSkipped[R]) Get() (*Run, error)

+ func (w *WaitGetRunJobTerminatedOrSkipped[R]) GetWithTimeout(timeout time.Duration) (*Run, error)

+ func (w *WaitGetRunJobTerminatedOrSkipped[R]) OnProgress(callback func(*Run)) *WaitGetRunJobTerminatedOrSkipped[R]

May 22, 2023

Changes in this version

type CreateJob

+ NotificationSettings *JobNotificationSettings

+ type JobNotificationSettings struct

+ NoAlertForCanceledRuns bool

+ NoAlertForSkippedRuns bool

type JobSettings

+ NotificationSettings *JobNotificationSettings

type JobTaskSettings

+ NotificationSettings *TaskNotificationSettings

type RunSubmitTaskSettings

+ SqlTask *SqlTask

type SqlTask

+ File *SqlTaskFile

+ type SqlTaskFile struct

+ Path string

type SubmitRun

+ NotificationSettings *JobNotificationSettings

+ type TaskEmailNotifications struct

+ OnFailure []string

+ OnStart []string

+ OnSuccess []string

+ type TaskNotificationSettings struct

+ AlertOnLastAttempt bool

+ NoAlertForCanceledRuns bool

+ NoAlertForSkippedRuns bool

Apr 20, 2023

Changes in this version

+ type ExportRunRequest struct

+ RunId int64

+ ViewsToExport ViewsToExport

+ type GetJobRequest struct

+ JobId int64

+ type GetRunOutputRequest struct

+ RunId int64

+ type GetRunRequest struct

+ IncludeHistory bool

+ RunId int64

+ type ListJobsRequest struct

+ ExpandTasks bool

+ Limit int

+ Name string

+ Offset int

+ type ListRunsRequest struct

+ ActiveOnly bool

+ CompletedOnly bool

+ ExpandTasks bool

+ JobId int64

+ Limit int

+ Offset int

+ RunType ListRunsRunType

+ StartTimeFrom int

+ StartTimeTo int

type SparkPythonTask

+ Source SparkPythonTaskSource

+ type SparkPythonTaskSource string

+ const SparkPythonTaskSourceGit

+ const SparkPythonTaskSourceWorkspace

+ func (spts *SparkPythonTaskSource) Set(v string) error

+ func (spts *SparkPythonTaskSource) String() string

+ func (spts *SparkPythonTaskSource) Type() string

Mar 8, 2023

Changes in this version

type BaseRun

+ Continuous *Continuous

+ type Continuous struct

+ PauseStatus ContinuousPauseStatus

+ type ContinuousPauseStatus string

+ const ContinuousPauseStatusPaused

+ const ContinuousPauseStatusUnpaused

+ func (cps *ContinuousPauseStatus) Set(v string) error

+ func (cps *ContinuousPauseStatus) String() string

+ func (cps *ContinuousPauseStatus) Type() string

type CreateJob

+ Continuous *Continuous

+ Trigger *TriggerSettings

+ type FileArrivalTriggerSettings struct

+ MinTimeBetweenTriggerSeconds int

+ Url string

+ WaitAfterLastChangeSeconds int

type Job

+ TriggerHistory *TriggerHistory

type JobSettings

+ Continuous *Continuous

+ Trigger *TriggerSettings

type Run

+ Continuous *Continuous

+ type TriggerEvaluation struct

+ Description string

+ RunId int64

+ Timestamp int64

+ type TriggerHistory struct

+ LastFailed *TriggerEvaluation

+ LastNotTriggered *TriggerEvaluation

+ LastTriggered *TriggerEvaluation

+ type TriggerSettings struct

+ FileArrival *FileArrivalTriggerSettings

+ PauseStatus TriggerSettingsPauseStatus

+ type TriggerSettingsPauseStatus string

+ const TriggerSettingsPauseStatusPaused

+ const TriggerSettingsPauseStatusUnpaused

+ func (tsps *TriggerSettingsPauseStatus) Set(v string) error

+ func (tsps *TriggerSettingsPauseStatus) String() string

+ func (tsps *TriggerSettingsPauseStatus) Type() string

type TriggerType

+ const TriggerTypeFileArrival

Feb 17, 2023

Changes in this version

type SqlAlertOutput

+ AlertState SqlAlertState

+ type SqlAlertState string

+ const SqlAlertStateOk

+ const SqlAlertStateTriggered

+ const SqlAlertStateUnknown

+ func (sas *SqlAlertState) Set(v string) error

+ func (sas *SqlAlertState) String() string

+ func (sas *SqlAlertState) Type() string

type SqlDashboardOutput

+ WarehouseId string

type SqlTaskAlert

+ PauseSubscriptions bool

+ Subscriptions []SqlTaskSubscription

type SqlTaskDashboard

+ CustomSubject string

+ PauseSubscriptions bool

+ Subscriptions []SqlTaskSubscription

+ type SqlTaskSubscription struct

+ DestinationId string

+ UserName string

Feb 3, 2023

Changes in this version

+ type BaseJob struct

+ CreatedTime int64

+ CreatorUserName string

+ JobId int64

+ Settings *JobSettings

+ type BaseRun struct

+ AttemptNumber int

+ CleanupDuration int64

+ ClusterInstance *ClusterInstance

+ ClusterSpec *ClusterSpec

+ CreatorUserName string

+ EndTime int64

+ ExecutionDuration int64

+ GitSource *GitSource

+ JobClusters []JobCluster

+ JobId int64

+ NumberInJob int64

+ OriginalAttemptRunId int64

+ OverridingParameters *RunParameters

+ RunDuration int

+ RunId int64

+ RunName string

+ RunPageUrl string

+ RunType RunType

+ Schedule *CronSchedule

+ SetupDuration int64

+ StartTime int64

+ State *RunState

+ Tasks []RunTask

+ Trigger TriggerType

type DbtTask

+ Catalog string

type JobsAPI

+ func (a *JobsAPI) BaseJobSettingsNameToJobIdMap(ctx context.Context, request List) (map[string]int64, error)

Dec 23, 2022

Changes in this version

type CreateJob

+ WebhookNotifications *JobWebhookNotifications

type CreateJobFormat

+ func (cjf *CreateJobFormat) Set(v string) error

+ func (cjf *CreateJobFormat) String() string

+ func (cjf *CreateJobFormat) Type() string

type CronSchedulePauseStatus

+ func (csps *CronSchedulePauseStatus) Set(v string) error

+ func (csps *CronSchedulePauseStatus) String() string

+ func (csps *CronSchedulePauseStatus) Type() string

type GitSourceGitProvider

+ func (gsgp *GitSourceGitProvider) Set(v string) error

+ func (gsgp *GitSourceGitProvider) String() string

+ func (gsgp *GitSourceGitProvider) Type() string

type JobSettings

+ WebhookNotifications *JobWebhookNotifications

type JobSettingsFormat

+ func (jsf *JobSettingsFormat) Set(v string) error

+ func (jsf *JobSettingsFormat) String() string

+ func (jsf *JobSettingsFormat) Type() string

+ type JobWebhookNotifications struct

+ OnFailure []JobWebhookNotificationsOnFailureItem

+ OnStart []JobWebhookNotificationsOnStartItem

+ OnSuccess []JobWebhookNotificationsOnSuccessItem

+ type JobWebhookNotificationsOnFailureItem struct

+ Id string

+ type JobWebhookNotificationsOnStartItem struct

+ Id string

+ type JobWebhookNotificationsOnSuccessItem struct

+ Id string

type ListRunsRunType

+ func (lrrt *ListRunsRunType) Set(v string) error

+ func (lrrt *ListRunsRunType) String() string

+ func (lrrt *ListRunsRunType) Type() string

type NotebookTaskSource

+ func (nts *NotebookTaskSource) Set(v string) error

+ func (nts *NotebookTaskSource) String() string

+ func (nts *NotebookTaskSource) Type() string

type RepairHistoryItemType

+ func (rhit *RepairHistoryItemType) Set(v string) error

+ func (rhit *RepairHistoryItemType) String() string

+ func (rhit *RepairHistoryItemType) Type() string

type Run

+ RunDuration int

type RunLifeCycleState

+ const RunLifeCycleStateBlocked

+ const RunLifeCycleStateWaitingForRetry

+ func (rlcs *RunLifeCycleState) Set(v string) error

+ func (rlcs *RunLifeCycleState) String() string

+ func (rlcs *RunLifeCycleState) Type() string

type RunResultState

+ func (rrs *RunResultState) Set(v string) error

+ func (rrs *RunResultState) String() string

+ func (rrs *RunResultState) Type() string

type RunType

+ func (rt *RunType) Set(v string) error

+ func (rt *RunType) String() string

+ func (rt *RunType) Type() string

type SqlDashboardWidgetOutputStatus

+ func (sdwos *SqlDashboardWidgetOutputStatus) Set(v string) error

+ func (sdwos *SqlDashboardWidgetOutputStatus) String() string

+ func (sdwos *SqlDashboardWidgetOutputStatus) Type() string

type SubmitRun

+ WebhookNotifications *JobWebhookNotifications

type TriggerType

+ func (tt *TriggerType) Set(v string) error

+ func (tt *TriggerType) String() string

+ func (tt *TriggerType) Type() string

type ViewType

+ func (vt *ViewType) Set(v string) error

+ func (vt *ViewType) String() string

+ func (vt *ViewType) Type() string

type ViewsToExport

+ func (vte *ViewsToExport) Set(v string) error

+ func (vte *ViewsToExport) String() string

+ func (vte *ViewsToExport) Type() string

Nov 30, 2022

Changes in this version

+ type AccessControlRequest struct

+ GroupName string

+ PermissionLevel any

+ ServicePrincipalName string

+ UserName string

+ type CancelAllRuns struct

+ JobId int64

+ type CancelRun struct

+ RunId int64

+ type ClusterInstance struct

+ ClusterId string

+ SparkContextId string

+ type ClusterSpec struct

+ ExistingClusterId string

+ Libraries []libraries.Library

+ NewCluster *clusters.CreateCluster

+ type CreateJob struct

+ AccessControlList []AccessControlRequest

+ EmailNotifications *JobEmailNotifications

+ Format CreateJobFormat

+ GitSource *GitSource

+ JobClusters []JobCluster

+ MaxConcurrentRuns int

+ Name string

+ Schedule *CronSchedule

+ Tags map[string]string

+ Tasks []JobTaskSettings

+ TimeoutSeconds int

+ type CreateJobFormat string

+ const CreateJobFormatMultiTask

+ const CreateJobFormatSingleTask

+ type CreateResponse struct

+ JobId int64

+ type CronSchedule struct

+ PauseStatus CronSchedulePauseStatus

+ QuartzCronExpression string

+ TimezoneId string

+ type CronSchedulePauseStatus string

+ const CronSchedulePauseStatusPaused

+ const CronSchedulePauseStatusUnpaused

+ type DbtOutput struct

+ ArtifactsHeaders any

+ ArtifactsLink string

+ type DbtTask struct

+ Commands []string

+ ProfilesDirectory string

+ ProjectDirectory string

+ Schema string

+ WarehouseId string

+ type DeleteJob struct

+ JobId int64

+ type DeleteRun struct

+ RunId int64

+ type ExportRun struct

+ RunId int64

+ ViewsToExport ViewsToExport

+ type ExportRunOutput struct

+ Views []ViewItem

+ type Get struct

+ JobId int64

+ type GetRun struct

+ IncludeHistory bool

+ RunId int64

+ type GetRunOutput struct

+ RunId int64

+ type GitSnapshot struct

+ UsedCommit string

+ type GitSource struct

+ GitBranch string

+ GitCommit string

+ GitProvider GitSourceGitProvider

+ GitSnapshot *GitSnapshot

+ GitTag string

+ GitUrl string

+ type GitSourceGitProvider string

+ const GitSourceGitProviderAwscodecommit

+ const GitSourceGitProviderAzuredevopsservices

+ const GitSourceGitProviderBitbucketcloud

+ const GitSourceGitProviderBitbucketserver

+ const GitSourceGitProviderGithub

+ const GitSourceGitProviderGithubenterprise

+ const GitSourceGitProviderGitlab

+ const GitSourceGitProviderGitlabenterpriseedition

+ type Job struct

+ CreatedTime int64

+ CreatorUserName string

+ JobId int64

+ RunAsUserName string

+ Settings *JobSettings

+ type JobCluster struct

+ JobClusterKey string

+ NewCluster *clusters.CreateCluster

+ type JobEmailNotifications struct

+ NoAlertForSkippedRuns bool

+ OnFailure []string

+ OnStart []string

+ OnSuccess []string

+ type JobSettings struct

+ EmailNotifications *JobEmailNotifications

+ Format JobSettingsFormat

+ GitSource *GitSource

+ JobClusters []JobCluster

+ MaxConcurrentRuns int

+ Name string

+ Schedule *CronSchedule

+ Tags map[string]string

+ Tasks []JobTaskSettings

+ TimeoutSeconds int

+ type JobSettingsFormat string

+ const JobSettingsFormatMultiTask

+ const JobSettingsFormatSingleTask

+ type JobTaskSettings struct

+ DbtTask *DbtTask

+ DependsOn []TaskDependenciesItem

+ Description string

+ EmailNotifications *JobEmailNotifications

+ ExistingClusterId string

+ JobClusterKey string

+ Libraries []libraries.Library

+ MaxRetries int

+ MinRetryIntervalMillis int

+ NewCluster *clusters.CreateCluster

+ NotebookTask *NotebookTask

+ PipelineTask *PipelineTask

+ PythonWheelTask *PythonWheelTask

+ RetryOnTimeout bool

+ SparkJarTask *SparkJarTask

+ SparkPythonTask *SparkPythonTask

+ SparkSubmitTask *SparkSubmitTask

+ SqlTask *SqlTask

+ TaskKey string

+ TimeoutSeconds int

+ type JobsAPI struct

+ func NewJobs(client *client.DatabricksClient) *JobsAPI

+ func (a *JobsAPI) CancelAllRuns(ctx context.Context, request CancelAllRuns) error

+ func (a *JobsAPI) CancelAllRunsByJobId(ctx context.Context, jobId int64) error

+ func (a *JobsAPI) CancelRun(ctx context.Context, request CancelRun) error

+ func (a *JobsAPI) CancelRunAndWait(ctx context.Context, cancelRun CancelRun, options ...retries.Option[Run]) (*Run, error)

+ func (a *JobsAPI) CancelRunByRunId(ctx context.Context, runId int64) error

+ func (a *JobsAPI) CancelRunByRunIdAndWait(ctx context.Context, runId int64, options ...retries.Option[Run]) (*Run, error)

+ func (a *JobsAPI) Create(ctx context.Context, request CreateJob) (*CreateResponse, error)

+ func (a *JobsAPI) Delete(ctx context.Context, request DeleteJob) error

+ func (a *JobsAPI) DeleteByJobId(ctx context.Context, jobId int64) error

+ func (a *JobsAPI) DeleteRun(ctx context.Context, request DeleteRun) error

+ func (a *JobsAPI) DeleteRunByRunId(ctx context.Context, runId int64) error

+ func (a *JobsAPI) ExportRun(ctx context.Context, request ExportRun) (*ExportRunOutput, error)

+ func (a *JobsAPI) Get(ctx context.Context, request Get) (*Job, error)

+ func (a *JobsAPI) GetByJobId(ctx context.Context, jobId int64) (*Job, error)

+ func (a *JobsAPI) GetBySettingsName(ctx context.Context, name string) (*Job, error)

+ func (a *JobsAPI) GetRun(ctx context.Context, request GetRun) (*Run, error)

+ func (a *JobsAPI) GetRunAndWait(ctx context.Context, getRun GetRun, options ...retries.Option[Run]) (*Run, error)

+ func (a *JobsAPI) GetRunOutput(ctx context.Context, request GetRunOutput) (*RunOutput, error)

+ func (a *JobsAPI) GetRunOutputByRunId(ctx context.Context, runId int64) (*RunOutput, error)

+ func (a *JobsAPI) Impl() JobsService

+ func (a *JobsAPI) JobSettingsNameToJobIdMap(ctx context.Context, request List) (map[string]int64, error)

+ func (a *JobsAPI) ListAll(ctx context.Context, request List) ([]Job, error)

+ func (a *JobsAPI) ListRunsAll(ctx context.Context, request ListRuns) ([]Run, error)

+ func (a *JobsAPI) RepairRun(ctx context.Context, request RepairRun) (*RepairRunResponse, error)

+ func (a *JobsAPI) RepairRunAndWait(ctx context.Context, repairRun RepairRun, options ...retries.Option[Run]) (*Run, error)

+ func (a *JobsAPI) Reset(ctx context.Context, request ResetJob) error

+ func (a *JobsAPI) RunNow(ctx context.Context, request RunNow) (*RunNowResponse, error)

+ func (a *JobsAPI) RunNowAndWait(ctx context.Context, runNow RunNow, options ...retries.Option[Run]) (*Run, error)

+ func (a *JobsAPI) Submit(ctx context.Context, request SubmitRun) (*SubmitRunResponse, error)

+ func (a *JobsAPI) SubmitAndWait(ctx context.Context, submitRun SubmitRun, options ...retries.Option[Run]) (*Run, error)

+ func (a *JobsAPI) Update(ctx context.Context, request UpdateJob) error

+ func (a *JobsAPI) WithImpl(impl JobsService) *JobsAPI

+ type JobsService interface

+ CancelAllRuns func(ctx context.Context, request CancelAllRuns) error

+ CancelRun func(ctx context.Context, request CancelRun) error

+ Create func(ctx context.Context, request CreateJob) (*CreateResponse, error)

+ Delete func(ctx context.Context, request DeleteJob) error

+ DeleteRun func(ctx context.Context, request DeleteRun) error

+ ExportRun func(ctx context.Context, request ExportRun) (*ExportRunOutput, error)

+ Get func(ctx context.Context, request Get) (*Job, error)

+ GetRun func(ctx context.Context, request GetRun) (*Run, error)

+ GetRunOutput func(ctx context.Context, request GetRunOutput) (*RunOutput, error)

+ List func(ctx context.Context, request List) (*ListJobsResponse, error)

+ ListRuns func(ctx context.Context, request ListRuns) (*ListRunsResponse, error)

+ RepairRun func(ctx context.Context, request RepairRun) (*RepairRunResponse, error)

+ Reset func(ctx context.Context, request ResetJob) error

+ RunNow func(ctx context.Context, request RunNow) (*RunNowResponse, error)

+ Submit func(ctx context.Context, request SubmitRun) (*SubmitRunResponse, error)

+ Update func(ctx context.Context, request UpdateJob) error

+ type List struct

+ ExpandTasks bool

+ Limit int

+ Name string

+ Offset int

+ type ListJobsResponse struct

+ HasMore bool

+ Jobs []Job

+ type ListRuns struct

+ ActiveOnly bool

+ CompletedOnly bool

+ ExpandTasks bool

+ JobId int64

+ Limit int

+ Offset int

+ RunType ListRunsRunType

+ StartTimeFrom int

+ StartTimeTo int

+ type ListRunsResponse struct

+ HasMore bool

+ Runs []Run

+ type ListRunsRunType string

+ const ListRunsRunTypeJobRun

+ const ListRunsRunTypeSubmitRun

+ const ListRunsRunTypeWorkflowRun

+ type NotebookOutput struct

+ Result string

+ Truncated bool

+ type NotebookTask struct

+ BaseParameters map[string]any

+ NotebookPath string

+ Source NotebookTaskSource

+ type NotebookTaskSource string

+ const NotebookTaskSourceGit

+ const NotebookTaskSourceWorkspace

+ type PipelineParams struct

+ FullRefresh bool

+ type PipelineTask struct

+ FullRefresh bool

+ PipelineId string

+ type PythonWheelTask struct

+ EntryPoint string

+ NamedParameters any

+ PackageName string

+ Parameters []string

+ type RepairHistoryItem struct

+ EndTime int64

+ Id int64

+ StartTime int64

+ State *RunState

+ TaskRunIds []int64

+ Type RepairHistoryItemType

+ type RepairHistoryItemType string

+ const RepairHistoryItemTypeOriginal

+ const RepairHistoryItemTypeRepair

+ type RepairRun struct

+ DbtCommands []string

+ JarParams []string

+ LatestRepairId int64

+ NotebookParams map[string]string

+ PipelineParams *PipelineParams

+ PythonNamedParams map[string]string

+ PythonParams []string

+ RerunAllFailedTasks bool

+ RerunTasks []string

+ RunId int64

+ SparkSubmitParams []string

+ SqlParams any

+ type RepairRunResponse struct

+ RepairId int64

+ type ResetJob struct

+ JobId int64

+ NewSettings *JobSettings

+ type Run struct

+ AttemptNumber int

+ CleanupDuration int64

+ ClusterInstance *ClusterInstance

+ ClusterSpec *ClusterSpec

+ CreatorUserName string

+ EndTime int64

+ ExecutionDuration int64

+ GitSource *GitSource

+ JobClusters []JobCluster

+ JobId int64

+ NumberInJob int64

+ OriginalAttemptRunId int64

+ OverridingParameters *RunParameters

+ RepairHistory []RepairHistoryItem

+ RunId int64

+ RunName string

+ RunPageUrl string

+ RunType RunType

+ Schedule *CronSchedule

+ SetupDuration int64

+ StartTime int64

+ State *RunState

+ Tasks []RunTask

+ Trigger TriggerType

+ type RunLifeCycleState string

+ const RunLifeCycleStateInternalError

+ const RunLifeCycleStatePending

+ const RunLifeCycleStateRunning

+ const RunLifeCycleStateSkipped

+ const RunLifeCycleStateTerminated

+ const RunLifeCycleStateTerminating

+ type RunNow struct

+ DbtCommands []string

+ IdempotencyToken string

+ JarParams []string

+ JobId int64

+ NotebookParams map[string]string

+ PipelineParams *PipelineParams

+ PythonNamedParams map[string]string

+ PythonParams []string

+ SparkSubmitParams []string

+ SqlParams any

+ type RunNowResponse struct

+ NumberInJob int64

+ RunId int64

+ type RunOutput struct

+ DbtOutput *DbtOutput

+ Error string

+ ErrorTrace string

+ Logs string

+ LogsTruncated bool

+ Metadata *Run

+ NotebookOutput *NotebookOutput

+ SqlOutput *SqlOutput

+ type RunParameters struct

+ DbtCommands []string

+ JarParams []string

+ NotebookParams map[string]string

+ PipelineParams *PipelineParams

+ PythonNamedParams map[string]string

+ PythonParams []string

+ SparkSubmitParams []string

+ SqlParams any

+ type RunResultState string

+ const RunResultStateCanceled

+ const RunResultStateFailed

+ const RunResultStateSuccess

+ const RunResultStateTimedout

+ type RunState struct

+ LifeCycleState RunLifeCycleState

+ ResultState RunResultState

+ StateMessage string

+ UserCancelledOrTimedout bool

+ type RunSubmitTaskSettings struct

+ DependsOn []TaskDependenciesItem

+ ExistingClusterId string

+ Libraries []libraries.Library

+ NewCluster *clusters.CreateCluster

+ NotebookTask *NotebookTask

+ PipelineTask *PipelineTask

+ PythonWheelTask *PythonWheelTask

+ SparkJarTask *SparkJarTask

+ SparkPythonTask *SparkPythonTask

+ SparkSubmitTask *SparkSubmitTask

+ TaskKey string

+ TimeoutSeconds int

+ type RunTask struct

+ AttemptNumber int

+ CleanupDuration int64

+ ClusterInstance *ClusterInstance

+ DbtTask *DbtTask

+ DependsOn []TaskDependenciesItem

+ Description string

+ EndTime int64

+ ExecutionDuration int64

+ ExistingClusterId string

+ GitSource *GitSource

+ Libraries []libraries.Library

+ NewCluster *clusters.CreateCluster

+ NotebookTask *NotebookTask

+ PipelineTask *PipelineTask

+ PythonWheelTask *PythonWheelTask

+ RunId int64

+ SetupDuration int64

+ SparkJarTask *SparkJarTask

+ SparkPythonTask *SparkPythonTask

+ SparkSubmitTask *SparkSubmitTask

+ SqlTask *SqlTask

+ StartTime int64

+ State *RunState

+ TaskKey string

+ type RunType string

+ const RunTypeJobRun

+ const RunTypeSubmitRun

+ const RunTypeWorkflowRun

+ type SparkJarTask struct

+ JarUri string

+ MainClassName string

+ Parameters []string

+ type SparkPythonTask struct

+ Parameters []string

+ PythonFile string

+ type SparkSubmitTask struct

+ Parameters []string

+ type SqlAlertOutput struct

+ OutputLink string

+ QueryText string

+ SqlStatements *SqlStatementOutput

+ WarehouseId string

+ type SqlDashboardOutput struct

+ Widgets *SqlDashboardWidgetOutput

+ type SqlDashboardWidgetOutput struct

+ EndTime int64

+ Error *SqlOutputError

+ OutputLink string

+ StartTime int64

+ Status SqlDashboardWidgetOutputStatus

+ WidgetId string

+ WidgetTitle string

+ type SqlDashboardWidgetOutputStatus string

+ const SqlDashboardWidgetOutputStatusCancelled

+ const SqlDashboardWidgetOutputStatusFailed

+ const SqlDashboardWidgetOutputStatusPending

+ const SqlDashboardWidgetOutputStatusRunning

+ const SqlDashboardWidgetOutputStatusSuccess

+ type SqlOutput struct

+ AlertOutput *SqlAlertOutput

+ DashboardOutput *SqlDashboardOutput

+ QueryOutput *SqlQueryOutput

+ type SqlOutputError struct

+ Message string

+ type SqlQueryOutput struct

+ OutputLink string

+ QueryText string

+ SqlStatements *SqlStatementOutput

+ WarehouseId string

+ type SqlStatementOutput struct

+ LookupKey string

+ type SqlTask struct

+ Alert *SqlTaskAlert

+ Dashboard *SqlTaskDashboard

+ Parameters any

+ Query *SqlTaskQuery

+ WarehouseId string

+ type SqlTaskAlert struct

+ AlertId string

+ type SqlTaskDashboard struct

+ DashboardId string

+ type SqlTaskQuery struct

+ QueryId string

+ type SubmitRun struct

+ AccessControlList []AccessControlRequest

+ GitSource *GitSource

+ IdempotencyToken string

+ RunName string

+ Tasks []RunSubmitTaskSettings

+ TimeoutSeconds int

+ type SubmitRunResponse struct

+ RunId int64

+ type TaskDependenciesItem struct

+ TaskKey string

+ type TriggerType string

+ const TriggerTypeOneTime

+ const TriggerTypePeriodic

+ const TriggerTypeRetry

+ type UpdateJob struct

+ FieldsToRemove []string

+ JobId int64

+ NewSettings *JobSettings

+ type ViewItem struct

+ Content string

+ Name string

+ Type ViewType

+ type ViewType string

+ const ViewTypeDashboard

+ const ViewTypeNotebook

+ type ViewsToExport string

+ const ViewsToExportAll

+ const ViewsToExportCode

+ const ViewsToExportDashboards