Skip to content

Commit 8140238

Browse files
authored
Add trigger info to the pipeline run metadata (#4106)
1 parent e384f30 commit 8140238

File tree

2 files changed

+23
-0
lines changed

2 files changed

+23
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -271,6 +271,10 @@ class PipelineRunResponseMetadata(ProjectScopedResponseMetadata):
271271
default=False,
272272
description="Whether a template can be created from this run.",
273273
)
274+
trigger_info: Optional[PipelineRunTriggerInfo] = Field(
275+
default=None,
276+
title="Trigger information for the pipeline run.",
277+
)
274278

275279

276280
class PipelineRunResponseResources(ProjectScopedResponseResources):

src/zenml/zen_stores/schemas/pipeline_run_schemas.py

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@
4343
PipelineRunResponse,
4444
PipelineRunResponseBody,
4545
PipelineRunResponseMetadata,
46+
PipelineRunTriggerInfo,
4647
PipelineRunUpdate,
4748
RunMetadataEntry,
4849
)
@@ -565,6 +566,23 @@ def to_model(
565566
client_environment.pop("python_packages", None)
566567
orchestrator_environment.pop("python_packages", None)
567568

569+
trigger_info: Optional[PipelineRunTriggerInfo] = None
570+
if self.triggered_by and self.triggered_by_type:
571+
if (
572+
self.triggered_by_type
573+
== PipelineRunTriggeredByType.STEP_RUN.value
574+
):
575+
trigger_info = PipelineRunTriggerInfo(
576+
step_run_id=self.triggered_by,
577+
)
578+
elif (
579+
self.triggered_by_type
580+
== PipelineRunTriggeredByType.DEPLOYMENT.value
581+
):
582+
trigger_info = PipelineRunTriggerInfo(
583+
deployment_id=self.triggered_by,
584+
)
585+
568586
metadata = PipelineRunResponseMetadata(
569587
run_metadata=self.fetch_metadata(
570588
include_full_metadata=include_full_metadata
@@ -580,6 +598,7 @@ def to_model(
580598
if self.snapshot
581599
else None,
582600
is_templatable=is_templatable,
601+
trigger_info=trigger_info,
583602
)
584603

585604
resources = None

0 commit comments

Comments
 (0)