Skip to content

Commit 68682eb

Browse files
icywang86ruiRui Wang Napieralski
andauthored
fix: assert step execution first in pipeline test (#2076)
* fix: assert step execution first in pipeline test * use Dict.get Co-authored-by: Rui Wang Napieralski <[email protected]>
1 parent 8ca9db1 commit 68682eb

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

tests/integ/test_workflow.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -506,15 +506,17 @@ def test_training_job_with_debugger(
506506
except WaiterError:
507507
pass
508508
execution_steps = execution.list_steps()
509-
training_job_arn = execution_steps[0]["Metadata"]["TrainingJob"]["Arn"]
510-
job_description = sagemaker_session.sagemaker_client.describe_training_job(
511-
TrainingJobName=training_job_arn.split("/")[1]
512-
)
513509

514510
assert len(execution_steps) == 1
511+
assert execution_steps[0].get("FailureReason", "") == ""
515512
assert execution_steps[0]["StepName"] == "pytorch-train"
516513
assert execution_steps[0]["StepStatus"] == "Succeeded"
517514

515+
training_job_arn = execution_steps[0]["Metadata"]["TrainingJob"]["Arn"]
516+
job_description = sagemaker_session.sagemaker_client.describe_training_job(
517+
TrainingJobName=training_job_arn.split("/")[1]
518+
)
519+
518520
for index, rule in enumerate(rules):
519521
config = job_description["DebugRuleConfigurations"][index]
520522
assert config["RuleConfigurationName"] == rule.name

0 commit comments

Comments
 (0)