Skip to content

feat: test resubscription to the task#535

Merged
kdziedzic70 merged 1 commit intoimplement-itk-servicefrom
feat/test-task-resubscribing
May 4, 2026
Merged

feat: test resubscription to the task#535
kdziedzic70 merged 1 commit intoimplement-itk-servicefrom
feat/test-task-resubscribing

Conversation

@kdziedzic70
Copy link
Copy Markdown
Contributor

Description

Thank you for opening a Pull Request!
Before submitting your PR, there are a few things you can do to make sure it goes smoothly:

Fixes #<issue_number_goes_here> 🦕

Copy link
Copy Markdown
Contributor

@gemini-code-assist gemini-code-assist Bot left a comment

Choose a reason for hiding this comment

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

Code Review

This pull request introduces a 'resubscribe' behavior across Go and Python agents, allowing tasks to be held in a working state for later retrieval. It adds a 'hold_task' field to the protobuf definitions and implements periodic status updates. Review feedback suggests restoring commented-out task enrollment in the Python v03 agent, re-enabling the full integration test suite, correcting a recurring typo in the 'task-finnished' sentinel string, and optimizing JSON imports in the test library.

Comment thread itk/agents/python/v03/main.py Outdated
Comment thread itk/run_tests.py Outdated
Comment thread itk/agents/go/v03/main.go Outdated
Comment thread itk/testlib.py
Comment thread itk/testlib.py Outdated
@kdziedzic70 kdziedzic70 changed the title feat: test resubscription to the task [WIP]feat: test resubscription to the task Apr 24, 2026
@kdziedzic70 kdziedzic70 force-pushed the feat/test-task-resubscribing branch 17 times, most recently from cef7204 to cec44ac Compare April 30, 2026 09:04
@kdziedzic70 kdziedzic70 changed the title [WIP]feat: test resubscription to the task feat: test resubscription to the task Apr 30, 2026
Comment thread itk/agents/go/v10/main.go
if call.Streaming {
if call.GetResubscribe() != nil {
return e.handleCallAgentWithResubscribe(ctx, client, wrappedMsg, call.AgentCardUri)
} else if call.Streaming {
Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Suggested change
} else if call.Streaming {
if call.Streaming {

Comment thread itk/run_tests.py
Comment thread itk/logs/.gitkeep Outdated
@kdziedzic70 kdziedzic70 force-pushed the feat/test-task-resubscribing branch 2 times, most recently from 96057f7 to 8069d81 Compare May 4, 2026 09:05
@kdziedzic70 kdziedzic70 force-pushed the feat/test-task-resubscribing branch from 8069d81 to 6af8df7 Compare May 4, 2026 09:09
@kdziedzic70 kdziedzic70 merged commit f38425b into implement-itk-service May 4, 2026
@kdziedzic70 kdziedzic70 deleted the feat/test-task-resubscribing branch May 4, 2026 09:28
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