Feature/event triggers by Json-Andriopoulos · Pull Request #4692 · zenml-io/zenml

Json-Andriopoulos · 2026-04-07T06:57:24Z

Describe changes

This feature introduces the concept of platform event triggers.

Platform event triggers are a type of triggers that users can set to "trigger" downstream execution based on a ZenML event (for instance a pipeline run completes).

This PR introduces the full backend management of this new trigger type functionality (CLI, SDK, etc.)

Pre-requisites

Please ensure you have done the following:

I have read the CONTRIBUTING.md document.
I have added tests to cover my changes.
I have based my new branch on develop and the open PR is targeting develop. If your branch wasn't based on develop read Contribution guide on rebasing branch to develop.
IMPORTANT: I made sure that my changes are reflected properly in the following resources:
- ZenML Docs
- Dashboard: Needs to be communicated to the frontend team.
- Templates: Might need adjustments (that are not reflected in the template tests) in case of non-breaking changes and deprecations.
- Projects: Depending on the version dependencies, different projects might get affected.

Types of changes

Bug fix (non-breaking change which fixes an issue)
New feature (non-breaking change which adds functionality)
Breaking change (fix or feature that would cause existing functionality to change)
Other (add details above)

stefannica · 2026-04-10T18:09:27Z

+    trigger_type: Literal["REST", "SCHEDULE", "WEBHOOK", "PLATFORM_EVENT"]
    trigger_id: UUID | None = None
    scheduled_at: datetime | None = None
+    metadata: dict[str, Any] | None = None


Does it also seem logical to you that the scheduled_at field could also be part of this more generic metadata ? Or is it just me ?

stefannica · 2026-04-15T13:22:19Z

    return request_manager().current_request
+
+
+async def register_event_handlers() -> None:


This should be register_platform_event_handler instead. It should create the platform event handler instance based on the source path in the server config and (maybe) register it with the dispatcher. Even better if the class registers itself with the dispatcher singleton when created.

stefannica · 2026-04-15T14:17:48Z

+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+#  or implied. See the License for the specific language governing
+#  permissions and limitations under the License.
+"""Utility functions to manage platform event triggers."""


Loving this !!!! This is the kind of UX that makes my heart melt.

stefannica · 2026-04-15T19:37:16Z

@claude /full-review

claude · 2026-04-15T19:38:08Z

Claude finished @stefannica's task in 0s —— View job

I'll analyze this and get back to you.

stefannica · 2026-04-16T07:52:22Z

@claude /full-review

strickvl · 2026-04-16T08:29:11Z

@claude /full-review

claude · 2026-04-16T08:41:57Z

Claude finished @stefannica's task in 0s —— View job

I'll analyze this and get back to you.

claude · 2026-04-16T09:11:00Z

Claude finished @strickvl's task in 0s —— View job

I'll analyze this and get back to you.

github-actions · 2026-04-16T09:48:15Z

Documentation Link Check Results

❌ Absolute links check failed
There are broken absolute links in the documentation. See workflow logs for details
❌ Relative links check failed
There are broken relative links in the documentation. See workflow logs for details
_{Last checked: 2026-04-17 10:32:25 UTC}

github-actions · 2026-04-16T12:46:22Z

🔍 Broken Links Report

Summary

📁 Files with broken links: 2
🔗 Total broken links: 4
📄 Broken markdown links: 4
🖼️ Broken image links: 0
⚠️ Broken reference placeholders: 0

Details

File	Link Type	Link Text	Broken Path
`zenml-pro/resource-pools-core-concepts.md`	📄	"How preemption works"	`resource-pools-preemption.md`
`zenml-pro/resource-pools-examples.md`	📄	"How preemption works"	`resource-pools-preemption.md`
`zenml-pro/resource-pools-examples.md`	📄	"How preemption works"	`resource-pools-preemption.md`
`zenml-pro/resource-pools-examples.md`	📄	"How preemption works"	`resource-pools-preemption.md`

📂 Full file paths

/home/runner/work/zenml/zenml/scripts/../docs/book/getting-started/zenml-pro/resource-pools-core-concepts.md
/home/runner/work/zenml/zenml/scripts/../docs/book/getting-started/zenml-pro/resource-pools-examples.md
/home/runner/work/zenml/zenml/scripts/../docs/book/getting-started/zenml-pro/resource-pools-examples.md
/home/runner/work/zenml/zenml/scripts/../docs/book/getting-started/zenml-pro/resource-pools-examples.md

schustmi · 2026-04-17T09:41:32Z

+        default=None,
+        title="Extra information for trigger execution like upstream_run_id etc.",
+    )
+    pipeline_id: UUID | None = Field(


Why is this needed? There is resources.pipeline.id, which should always be included if the metadata is included?

Json-Andriopoulos requested a review from stefannica April 7, 2026 06:57

github-actions Bot added the enhancement New feature or request label Apr 7, 2026

bcdurak linked an issue Apr 7, 2026 that may be closed by this pull request

Pipeline Event Hooks #4626

Open

strickvl mentioned this pull request Apr 9, 2026

Add HTTP trigger support for flows zenml-io/kitaru#117

Open

Json-Andriopoulos commented Apr 9, 2026

View reviewed changes

Comment thread src/zenml/client.py

Json-Andriopoulos commented Apr 9, 2026

View reviewed changes

Comment thread src/zenml/enums.py Outdated

Json-Andriopoulos commented Apr 9, 2026

View reviewed changes

Comment thread src/zenml/models/v2/core/triggers.py Outdated

stefannica requested changes Apr 10, 2026

View reviewed changes

Json-Andriopoulos force-pushed the feature/event-triggers branch 2 times, most recently from b5dc2e3 to edc621a Compare April 15, 2026 07:10

Json-Andriopoulos requested a review from stefannica April 15, 2026 07:29

Json-Andriopoulos force-pushed the feature/event-triggers branch from edc621a to 955cf54 Compare April 15, 2026 10:56

stefannica requested changes Apr 15, 2026

View reviewed changes

Json-Andriopoulos force-pushed the feature/event-triggers branch from 92e6a51 to 0c67922 Compare April 15, 2026 17:15

stefannica approved these changes Apr 15, 2026

View reviewed changes

stefannica added the run-slow-ci Tag that is used to trigger the slow-ci label Apr 15, 2026

stefannica marked this pull request as ready for review April 15, 2026 18:38

Json-Andriopoulos added the release-notes Release notes will be attached and used publicly for this PR. label Apr 16, 2026

strickvl mentioned this pull request Apr 16, 2026

Fix empty PR number in Claude Code review workflow #4735

Merged

2 tasks

Json-Andriopoulos force-pushed the feature/event-triggers branch 2 times, most recently from 590c67d to aab06c4 Compare April 16, 2026 09:41

Json-Andriopoulos force-pushed the feature/event-triggers branch from 2654726 to 40fd95c Compare April 16, 2026 10:34

Extend data model for platform event triggers

9469ed5

Json-Andriopoulos added 16 commits April 16, 2026 15:36

Add platform-event trigger CLI methods

0398640

Remove unused data model

267ccce

Revert threaded dispatcher changes

280ddbe

Fix selectinload placing for trigger execution info

a5cda41

merge migrations

a817a8b

Remove running loop storage on FastAPI state

819f13a

Remove pub/sub package

c29f58c

Fix trigger_execution_info deserialisation bug

2d36fa4

CI fixes

e572354

bug fixes

20f6ca4

Extend docs with a platform event triggers section

7018f8e

bug fixes

6b94ac8

Check for repeated archivals

d1bbb97

bug fixes

3d18f6e

Decouple dispatcher from SQLAlchemy

b35f8c4

Update migration order

069d648

Json-Andriopoulos force-pushed the feature/event-triggers branch from 146a9fd to 069d648 Compare April 16, 2026 12:45

Json-Andriopoulos added 2 commits April 16, 2026 16:45

Fix pipeline run cascade deletions

983d2c5

TZ unaware next occurrence fix & tests

ea73e29

Json-Andriopoulos force-pushed the feature/event-triggers branch from 69f2534 to 009c1a7 Compare April 16, 2026 16:15

Snapshot/Trigger common project check

d169864

Json-Andriopoulos force-pushed the feature/event-triggers branch 2 times, most recently from 49a42ac to 8d7e63d Compare April 17, 2026 09:04

Extend test cases

028e584

Json-Andriopoulos force-pushed the feature/event-triggers branch from 8d7e63d to 028e584 Compare April 17, 2026 09:12

schustmi reviewed Apr 17, 2026

View reviewed changes

Docs: add upstream info and cyclic graph sections

b460c46

Json-Andriopoulos merged commit 2c84f71 into develop Apr 17, 2026
64 of 79 checks passed

Json-Andriopoulos deleted the feature/event-triggers branch April 17, 2026 12:21

		return request_manager().current_request


		async def register_event_handlers() -> None:

Conversation

Json-Andriopoulos commented Apr 7, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Describe changes

Pre-requisites

Types of changes

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

stefannica Apr 10, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

stefannica Apr 15, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

stefannica Apr 15, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

stefannica commented Apr 15, 2026

Uh oh!

claude Bot commented Apr 15, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

stefannica commented Apr 16, 2026

Uh oh!

strickvl commented Apr 16, 2026

Uh oh!

claude Bot commented Apr 16, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

claude Bot commented Apr 16, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

github-actions Bot commented Apr 16, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Documentation Link Check Results

Uh oh!

github-actions Bot commented Apr 16, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

🔍 Broken Links Report

Summary

Details

Uh oh!

schustmi Apr 17, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

Json-Andriopoulos commented Apr 7, 2026 •

edited

Loading

claude Bot commented Apr 15, 2026 •

edited

Loading

claude Bot commented Apr 16, 2026 •

edited

Loading

claude Bot commented Apr 16, 2026 •

edited

Loading

github-actions Bot commented Apr 16, 2026 •

edited

Loading

github-actions Bot commented Apr 16, 2026 •

edited

Loading