steve/databricks-cli
steve
/
databricks-cli
mirror of https://github.com/databricks/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Include permissions

This commit is contained in:
Pieter Noordhuis 2024-11-11 11:57:15 +01:00
parent 0cb3b5382e
commit b58a6fc099
No known key found for this signature in database
GPG Key ID: 12ACCCC104CF2930
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
experimental/dbx2dab/main.py
View File

@ -55,9 +55,6 @@ class Job:
def compute_base(self) -> Dict[str, any]: def compute_base(self) -> Dict[str, any]:
keys = list(self.configs.keys()) keys = list(self.configs.keys())
if len(keys) == 1:
return self.configs[keys[0]]
out = self.configs[keys[0]] out = self.configs[keys[0]]
for key in keys[1:]: for key in keys[1:]:
out = recursive_intersection(out, self.configs[key]) out = recursive_intersection(out, self.configs[key])
@ -70,12 +67,20 @@ class Job:
"schedule", "schedule",
"email_notifications", "email_notifications",
"git_source", "git_source",
"permissions",
"tasks", "tasks",
"job_clusters", "job_clusters",
] ]
obj = self.compute_base() obj = self.compute_base()
# DBX uses "access_control_list" per job.
# In DABs we use "permissions" for the whole job.
obj["permissions"] = [dict(e) for e in obj["access_control_list"]]
for permission in obj["permissions"]:
permission["level"] = permission["permission_level"]
permission.pop("permission_level")
return { return {
"resources": { "resources": {
"jobs": {self.normalized_key(): {k: obj[k] for k in ordered_keys}} "jobs": {self.normalized_key(): {k: obj[k] for k in ordered_keys}}