Skip to content

Commit 4e1d4e6

Browse files
committed
Rename attribute
1 parent e3653ce commit 4e1d4e6

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

src/zenml/models/v2/core/pipeline_run.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ class PipelineRunUpdate(BaseUpdate):
178178
max_length=STR_FIELD_MAX_LENGTH,
179179
)
180180
end_time: Optional[datetime] = None
181-
finished: Optional[bool] = Field(
181+
is_finished: Optional[bool] = Field(
182182
default=None,
183183
title="Whether the pipeline run is finished.",
184184
)

src/zenml/orchestrators/publish_utils.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ def publish_successful_pipeline_run(
134134
run_update=PipelineRunUpdate(
135135
status=ExecutionStatus.COMPLETED,
136136
end_time=utc_now(),
137-
finished=True,
137+
is_finished=True,
138138
),
139139
)
140140

@@ -155,7 +155,7 @@ def publish_failed_pipeline_run(
155155
run_update=PipelineRunUpdate(
156156
status=ExecutionStatus.FAILED,
157157
end_time=utc_now(),
158-
finished=True,
158+
is_finished=True,
159159
),
160160
)
161161

src/zenml/zen_stores/schemas/pipeline_run_schemas.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -712,7 +712,7 @@ def update(self, run_update: "PipelineRunUpdate") -> "PipelineRunSchema":
712712
if run_update.status_reason:
713713
self.status_reason = run_update.status_reason
714714

715-
if run_update.finished:
715+
if run_update.is_finished:
716716
self.in_progress = False
717717
elif self.snapshot and self.snapshot.is_dynamic:
718718
# In dynamic pipelines, we can't actually check if the run is

0 commit comments

Comments
 (0)