Skip to content

ref(workerchild): add produce future success/failure metrics#697

Merged
bmckerry merged 2 commits into
mainfrom
ben/taskbroker-producer-results
Jun 11, 2026
Merged

ref(workerchild): add produce future success/failure metrics#697
bmckerry merged 2 commits into
mainfrom
ben/taskbroker-producer-results

Conversation

@bmckerry

Copy link
Copy Markdown
Member

Adds observability to produce future outcomes.

@bmckerry bmckerry requested a review from a team as a code owner June 11, 2026 16:59

@cursor cursor Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Cursor Bugbot has reviewed your changes and found 1 potential issue.

Fix All in Cursor

❌ Bugbot Autofix is OFF. To automatically fix reported issues with cloud agents, enable autofix in the Cursor dashboard.

Reviewed by Cursor Bugbot for commit 37b5c16. Configure here.

Comment thread clients/python/src/taskbroker_client/worker/workerchild.py Outdated
Comment thread clients/python/src/taskbroker_client/worker/workerchild.py Outdated
retry_state = task.inflight.activation.retry_state
if not task.task_func.retry.max_attempts_reached(retry_state):
task.status = TASK_ACTIVATION_STATUS_RETRY
metrics.incr(

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Up to you, you may have one metric taskworker.worker.produce and have the tag status that can be success or failure. It makes it easier to count the total

@bmckerry bmckerry merged commit 4c5d662 into main Jun 11, 2026
27 checks passed
@bmckerry bmckerry deleted the ben/taskbroker-producer-results branch June 11, 2026 17:30
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.

3 participants