Skip to content

Commit 6ad6b41

Browse files
authored
Updated SDK for Delta Pipelines to match API PipelineSettings definition (#501)
1 parent 58639ff commit 6ad6b41

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

databricks_cli/sdk/service.py

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -977,7 +977,7 @@ def __init__(self, client):
977977
self.client = client
978978

979979
def create(self, id=None, name=None, storage=None, configuration=None, clusters=None,
980-
libraries=None, trigger=None, filters=None, allow_duplicate_names=None,
980+
libraries=None, trigger=None, filters=None, target=None, continuous=None, development=None, allow_duplicate_names=None,
981981
headers=None):
982982
_data = {}
983983
if id is not None:
@@ -1000,12 +1000,18 @@ def create(self, id=None, name=None, storage=None, configuration=None, clusters=
10001000
_data['filters'] = filters
10011001
if not isinstance(filters, dict):
10021002
raise TypeError('Expected databricks.Filters() or dict for field filters')
1003+
if target is not None:
1004+
_data['target'] = target
1005+
if continuous is not None:
1006+
_data['continuous'] = continuous
1007+
if development is not None:
1008+
_data['development'] = development
10031009
if allow_duplicate_names is not None:
10041010
_data['allow_duplicate_names'] = allow_duplicate_names
10051011
return self.client.perform_query('POST', '/pipelines', data=_data, headers=headers)
10061012

10071013
def deploy(self, pipeline_id=None, id=None, name=None, storage=None, configuration=None,
1008-
clusters=None, libraries=None, trigger=None, filters=None,
1014+
clusters=None, libraries=None, trigger=None, filters=None, target=None, continuous=None, development=None,
10091015
allow_duplicate_names=None, headers=None):
10101016
_data = {}
10111017
if id is not None:
@@ -1028,6 +1034,12 @@ def deploy(self, pipeline_id=None, id=None, name=None, storage=None, configurati
10281034
_data['filters'] = filters
10291035
if not isinstance(filters, dict):
10301036
raise TypeError('Expected databricks.Filters() or dict for field filters')
1037+
if target is not None:
1038+
_data['target'] = target
1039+
if continuous is not None:
1040+
_data['continuous'] = continuous
1041+
if development is not None:
1042+
_data['development'] = development
10311043
if allow_duplicate_names is not None:
10321044
_data['allow_duplicate_names'] = allow_duplicate_names
10331045
return self.client.perform_query('PUT', '/pipelines/{pipeline_id}'.format(pipeline_id=pipeline_id), data=_data,

0 commit comments

Comments
 (0)