pipeline_updates

Operations on a pipeline_updates resource.

Overview

Name	pipeline_updates
Type	Resource
Id	databricks_workspace.deltalivetables.pipeline_updates

Fields

Name	Datatype
cause	string
cluster_id	string
config	object
creation_time	integer
full_refresh	boolean
full_refresh_selection	array
pipeline_id	string
refresh_selection	array
state	string
update_id	string
validate_only	boolean

Methods

Name	Accessible by	Required Params	Description
getupdate	SELECT	pipeline_id, update_id, deployment_name	Gets an update from an active pipeline.
listupdates	SELECT	pipeline_id, deployment_name	List updates for an active pipeline.
startupdate	EXEC	pipeline_id, deployment_name	Starts a new update for the pipeline. If there is already an active update for the pipeline, the request will fail and the active update will remain running.

SELECT examples

pipeline_updates (listupdates)

SELECT
cause,
cluster_id,
config,
creation_time,
full_refresh,
full_refresh_selection,
pipeline_id,
refresh_selection,
state,
update_id,
validate_only
FROM databricks_workspace.deltalivetables.pipeline_updates
WHERE pipeline_id = '{{ pipeline_id }}' AND
deployment_name = '{{ deployment_name }}';

pipeline_updates (getupdate)

SELECT
cause,
cluster_id,
config,
creation_time,
full_refresh,
full_refresh_selection,
pipeline_id,
refresh_selection,
state,
update_id,
validate_only
FROM databricks_workspace.deltalivetables.pipeline_updates
WHERE pipeline_id = '{{ pipeline_id }}' AND
update_id = '{{ update_id }}' AND
deployment_name = '{{ deployment_name }}';