[Improvement-18039][Metrics] Add missing metrics for workflow and task state transitions#18038
Open
sanjana2505006 wants to merge 1 commit into
Open
[Improvement-18039][Metrics] Add missing metrics for workflow and task state transitions#18038sanjana2505006 wants to merge 1 commit into
sanjana2505006 wants to merge 1 commit into
Conversation
sanjana2505006
requested review from
SbloodyS,
caishunfeng and
ruanwenjun
as code owners
sanjana2505006
force-pushed
the
Improvement-Metrics
branch
from
990a504 to
6176e33
Compare
sanjana2505006
changed the title
sanjana2505006
changed the title
sanjana2505006
changed the title
sanjana2505006
changed the title
SbloodyS
reviewed
Mar 9, 2026
SbloodyS
left a comment
SbloodyS
left a comment
Member
There was a problem hiding this comment.
Please follow the pull request notice and create an issue first. @sanjana2505006
sanjana2505006
changed the title
sanjana2505006
force-pushed
the
Improvement-Metrics
branch
from
9c47397 to
c0013cc
Compare
Contributor
Author
Member
|
Please check the failed CI. @sanjana2505006 |
Contributor
Author
|
Sure, @SbloodyS, I have an exam today. I’ll take a look at the failed CI once I’m done 😃... |
sanjana2505006
force-pushed
the
Improvement-Metrics
branch
from
2a2647b to
edeef4e
Compare
Contributor
Author
|
Hello @SbloodyS, I've updated the PR to address the CI failures. Please have a look when you have time and share your feedback. Thank you! |
Member
|
UT still failed. @sanjana2505006 |
ruanwenjun
reviewed
Mar 20, 2026
ruanwenjun
left a comment
ruanwenjun
left a comment
Member
There was a problem hiding this comment.
Thanks for your PR.
It might be better to add event metrics first.
WorkflowEventBusFireWorker#doFireSingleWorkflowEventBus
We may need to provide a public method to handle changes in instance state, and then use listeners or similar mechanisms to update the metrics.
So it’s not suitable to add this directly at the moment, but I’ll be doing that soon.
sanjana2505006
force-pushed
the
Improvement-Metrics
branch
from
f4919d7 to
e30a3d3
Compare
SbloodyS
reviewed
Mar 30, 2026
sanjana2505006
added a commit
to sanjana2505006/dolphinscheduler
that referenced
this pull request
Apr 2, 2026
…sage - Add back empty line in AbstractTaskStateAction.java line 199 as requested - Add incTaskInstanceByLifecycleEvent method to TaskMetrics to use TaskLifecycleEventType directly - Update WorkflowEventBusFireWorker to use new method instead of string comparisons - Add comprehensive tests for new lifecycle event method Addresses feedback from SbloodyS and ruanwenjun on PR apache#18038
sanjana2505006
force-pushed
the
Improvement-Metrics
branch
from
83a0f5d to
7469149
Compare
|
Contributor
Author
|
@SbloodyS I've updated the pr according to your feedback , please have a look |
…k state transitions Record workflow instance state changes in AbstractWorkflowStateAction, workflow generation duration in WorkflowExecutionFactory, and task lifecycle metrics via TaskLifecycleEventType in WorkflowEventBusFireWorker. Add unit tests for TaskMetrics and WorkflowInstanceMetrics. Co-authored-by: Cursor <cursoragent@cursor.com>
sanjana2505006
force-pushed
the
Improvement-Metrics
branch
from
817d2aa to
b5ae074
Compare
SbloodyS
requested changes
Jun 10, 2026
Comment on lines
+76
to
+81
| public void incTaskInstanceByState(final String state) { | ||
| if (taskInstanceCounters.get(state) == null) { | ||
| return; | ||
| } | ||
| taskInstanceCounters.get(state).increment(); | ||
| } |
Member
There was a problem hiding this comment.
We should store TaskLifecycleEventType.name() directly. You can refer to org.apache.dolphinscheduler.server.master.metrics.WorkflowInstanceMetrics
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Purpose
This PR adds missing metrics to the Master module to improve visibility into workflow and task execution states. It addresses the gap where several metrics classes were defined but not utilized in the core execution flow.
Proposed Changes
AbstractWorkflowStateAction.AbstractTaskStateAction.TaskTimeoutLifecycleEventHandler.WorkflowExecutionRunnableFactory.Verification
mvn spotless:apply.This PR closes #18039