You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Create a tuner with worker.NewCompositeTuner and resourcetuner.NewResourceBasedSlotSupplier as suggested in go-sdk docs
Set activity ResourceBasedSlotSupplierOptions.MaxSlots to something small like 4.
Start a worker with tuner set in worker.Options
Execute a workflow that starts a large amount of activities - few activities should be scheduled, and others should be schedule/stuck in pending state.
Expected Behavior
Activity SlotSupplier created with
resourcetuner.NewResourceBasedSlotSupplier
should release activity slots when they are completed.Actual Behavior
Activity slots are not released after task is completed. This causes scheduled activities to forever hand in
PENDING_ACTIVITY_STATE_SCHEDULED
state.I suspect because the SlotSupplier interface method ReleaseSlot is not implemented:
https://github.com/temporalio/sdk-go/blob/master/contrib/resourcetuner/resourcetuner.go#L204
Steps to Reproduce the Problem
worker.NewCompositeTuner
andresourcetuner.NewResourceBasedSlotSupplier
as suggested in go-sdk docsResourceBasedSlotSupplierOptions.MaxSlots
to something small like 4.Specifications
The text was updated successfully, but these errors were encountered: