Skip to content

Commit 47d70e4

Browse files
sararobcopybara-github
authored andcommitted
chore: fix pipeline job schedule system test
PiperOrigin-RevId: 570128541
1 parent 6a2f2aa commit 47d70e4

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

tests/system/aiplatform/test_pipeline_job_schedule.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,18 +34,19 @@ class TestPipelineJobSchedule(e2e_base.TestEndToEnd):
3434

3535
def test_create_get_pause_resume_update_list(self, shared_state):
3636
# Components:
37-
@dsl.component
3837
def train(
3938
number_of_epochs: int,
4039
learning_rate: float,
4140
):
4241
print(f"number_of_epochs={number_of_epochs}")
4342
print(f"learning_rate={learning_rate}")
4443

44+
train_op = dsl.component(train)
45+
4546
# Pipeline:
4647
@dsl.pipeline(name="system-test-training-pipeline")
4748
def training_pipeline(number_of_epochs: int = 2):
48-
train(
49+
train_op(
4950
number_of_epochs=number_of_epochs,
5051
learning_rate=0.1,
5152
)

0 commit comments

Comments
 (0)