Commit b775ca6
committed
Add ActivityCommandTask for outbound activity commands
- Define ActivityCommandTask in tasks package
- Add serialization/deserialization for ActivityCommandTask
- Add task generation in TaskGenerator
- Add batching logic in workflow task completed handler
- Forward WorkerControlTaskQueue through matching service
- Add unit tests for task generation and batching
- Add metrics support with command type1 parent 59a2ee2 commit b775ca6
25 files changed
Lines changed: 827 additions & 521 deletions
File tree
- api
- enums/v1
- persistence/v1
- common
- metrics
- persistence/serialization
- testing/testvars
- proto/internal/temporal/server/api
- enums/v1
- persistence/v1
- service/history
- api/respondworkflowtaskcompleted
- interfaces
- queues
- tasks
- workflow
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
0 commit comments