Hi, is it possible to update search attributes when a activity do retry?
We wanna to monitor worker and workflow status when start a branch of workflows. Such as,
- How many workflows on taskA “scheduled”
- How many workflows on taskA “processing”
- How many workflows on taskA “completed/failed”
Here are workflow code
1. UpsertSearchAttributes state taskA "scheduled"
2. ExecuteActivity "TaskA"
2.1 TaskA activity code will call signal workflow first
3. UpsertSearchAttributes state taskA "completed" or "failed"
To support state “processing” will be a little tricky:
Workflow code start a thread to handle signal background wait for signal coming, and upsert search attributes
But when Activity failed and backoff retry, we wanna to find a method to reset or update search attributes state to scheduled again.
Is there any idea can help?
We plan to add such functionality. I don’t think we will update the search attribute on the first retry as it can generate significant update traffic without much value. But updating it after retries exceeded some threshold makes perfect sense.
Nice to hear that.
But for long running task (maybe consume a few hour), the update traffic is acceptable.
That’s why the threshold should be configurable.
I have the same question. Search attributes would be wrong if the task is retried:
3.taskA failed and retry
4.now taskA at processing state
but in fact, task A should be scheduled state since there is no worker polled it.
You should not use search attributes for high rate of updates. So the state would be more like “activity didn’t complete within a specified timeout” and you’ll need to look at the specific workflow details to find out its exact state.