File tree Expand file tree Collapse file tree 3 files changed +5
-2
lines changed
src/databricks/labs/ucx/contexts
tests/integration/progress Expand file tree Collapse file tree 3 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -116,5 +116,5 @@ def workflow_run_recorder(self):
116
116
workflow_id = int (self .named_parameters ["job_id" ]),
117
117
workflow_run_id = int (self .named_parameters ["parent_run_id" ]),
118
118
workflow_run_attempt = int (self .named_parameters .get ("attempt" , 0 )),
119
- workflow_start_time = self .named_parameters ["workflow_start_time " ],
119
+ workflow_start_time = self .named_parameters ["start_time " ],
120
120
)
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ def test_workflow_run_recorder_records_workflow_run(installation_ctx) -> None:
9
9
"workflow" : "test" ,
10
10
"job_id" : "123" ,
11
11
"parent_run_id" : "456" ,
12
- "workflow_start_time " : start_time .isoformat (),
12
+ "start_time " : start_time .isoformat (),
13
13
}
14
14
ctx = installation_ctx .replace (named_parameters = named_parameters )
15
15
ctx .progress_tracking_installation .run ()
Original file line number Diff line number Diff line change @@ -16,6 +16,9 @@ def test_running_real_migration_progress_job(installation_ctx: MockInstallationC
16
16
installation_ctx .deployed_workflows .run_workflow ("assessment" )
17
17
assert installation_ctx .deployed_workflows .validate_step ("assessment" )
18
18
19
+ # After the assessment, a user (maybe) installs the progress tracking
20
+ installation_ctx .progress_tracking_installation .run ()
21
+
19
22
# Run the migration-progress workflow until completion.
20
23
installation_ctx .deployed_workflows .run_workflow ("migration-progress-experimental" )
21
24
assert installation_ctx .deployed_workflows .validate_step ("migration-progress-experimental" )
You can’t perform that action at this time.
0 commit comments