Skip to content

Conversation

@stellasia
Copy link
Contributor

@stellasia stellasia commented Dec 9, 2025

Description

This PR makes sure a PIPELINE_FAILED event is always sent to the event callback when pipeline fails. Consequences:

  • Had to move the event notifier from Orchestrator to Pipeline, since pipeline validation happens out of the Orchestrator
  • Moved the pipeline started and pipeline finished event to the pipeline so that we do not receive pipeline failed event without any pipeline started event
  • Moved the run_id creation in the Pipeline class for better code org

Type of Change

  • New feature
  • Bug fix
  • Breaking change
  • Documentation update
  • Project configuration change

Complexity

Note

Please provide an estimated complexity of this PR of either Low, Medium or High

Complexity:

How Has This Been Tested?

  • Unit tests
  • E2E tests
  • Manual tests

Checklist

The following requirements should have been met (depending on the changes in the branch):

  • Documentation has been updated
  • Unit tests have been updated
  • E2E tests have been updated
  • Examples have been updated
  • New files have copyright header
  • CLA (https://neo4j.com/developer/cla/) has been signed
  • CHANGELOG.md updated if appropriate

@stellasia stellasia marked this pull request as ready for review December 11, 2025 09:36
@stellasia stellasia requested a review from a team as a code owner December 11, 2025 09:36
@stellasia stellasia force-pushed the feature/pipeline-failure-events branch from 1d0ed47 to 2094545 Compare December 11, 2025 09:37
)
raise e
end_time = default_timer()
logger.debug(f"PIPELINE FINISHED {run_id} in {end_time - start_time}s")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: you may want to round the duration, otherwise it will show the duration with very high precision.

Copy link
Contributor

@serengil serengil left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@stellasia stellasia merged commit 06fe74f into neo4j:main Dec 11, 2025
9 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants