-
Notifications
You must be signed in to change notification settings - Fork 188
worker: delete taskState when task is stopped/finished #1606
Conversation
there's a check_metric script, which could be used in tests. |
|
||
func updateTaskState(task, sourceID string, stage pb.Stage) { | ||
if stage == pb.Stage_Stopped || stage == pb.Stage_Finished { | ||
taskState.DeleteAllAboutLabels(prometheus.Labels{"task": task, "source_id": sourceID}) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we might update the description of metics in dm.json and dm_instance.json
"The current state of subtasks..."
sleep 1 | ||
done | ||
|
||
echo "metric $metric_name has invalid value $metric" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
echo "metric $metric_name has invalid value $metric" | |
echo "metric $metric_name has invalid count $metric" |
/cc @GMHDBJD |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please resolve conflict. rest LGTM
/run-all-tests |
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
/lgtm
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by writing |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: 8572a71
|
integration test shardddl1 seems still unstable: |
Signed-off-by: ti-srebot <ti-srebot@pingcap.com>
cherry pick to release-2.0 in PR #1614 |
What problem does this PR solve?
fix #1594
What is changed and how it works?
delete taskState when task is stopped/finished
Check List
Tests
When task is running:
After task is stopped:
Related changes