Skip to content

Commit b53986a

Browse files
committed
populate object owner
1 parent 30872fc commit b53986a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/databricks/labs/ucx/sequencing/sequencing.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ def register_workflow_task(self, task: jobs.Task, job: jobs.Job, _graph: Depende
8383
object_type="TASK",
8484
object_id=task_id,
8585
object_name=task.task_key,
86-
object_owner="NONE",
87-
) # TODO object_owner
86+
object_owner=job_node.object_owner, # no task owner so use job one
87+
)
8888
job_node.required_steps.append(task_node)
8989
if task.existing_cluster_id:
9090
cluster_node = self.register_cluster(task.existing_cluster_id)
@@ -105,8 +105,8 @@ def register_workflow_job(self, job: jobs.Job) -> MigrationNode:
105105
object_type="JOB",
106106
object_id=str(job.job_id),
107107
object_name=job_name,
108-
object_owner="NONE",
109-
) # TODO object_owner
108+
object_owner=job.creator_user_name or "<UNKNOWN>",
109+
)
110110
top_level = True
111111
if job.settings and job.settings.job_clusters:
112112
for job_cluster in job.settings.job_clusters:

0 commit comments

Comments
 (0)