Skip to content

Commit cdf917f

Browse files
authored
Add access_control_list parameter to JobsService (#540)
This fixes #523.
1 parent f576b89 commit cdf917f

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

databricks_cli/sdk/service.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ def create_job(
5858
tags=None,
5959
format=None,
6060
dbt_task=None,
61+
access_control_list=None,
6162
):
6263
_data = {}
6364
if name is not None:
@@ -130,6 +131,8 @@ def create_job(
130131
_data['dbt_task'] = dbt_task
131132
if not isinstance(dbt_task, dict):
132133
raise TypeError('Expected databricks.DbtTask() or dict for field dbt_task')
134+
if access_control_list is not None:
135+
_data['access_control_list'] = access_control_list
133136
return self.client.perform_query(
134137
'POST', '/jobs/create', data=_data, headers=headers, version=version
135138
)
@@ -152,6 +155,7 @@ def submit_run(
152155
job_clusters=None,
153156
git_source=None,
154157
dbt_task=None,
158+
access_control_list=None,
155159
):
156160
_data = {}
157161
if run_name is not None:
@@ -204,6 +208,8 @@ def submit_run(
204208
_data['dbt_task'] = dbt_task
205209
if not isinstance(dbt_task, dict):
206210
raise TypeError('Expected databricks.DbtTask() or dict for field dbt_task')
211+
if access_control_list is not None:
212+
_data['access_control_list'] = access_control_list
207213
return self.client.perform_query(
208214
'POST', '/jobs/runs/submit', data=_data, headers=headers, version=version
209215
)

0 commit comments

Comments
 (0)