Reset Workflow in Java SDK

Community Support
21

That is the requirement Maxim, we have multiple third party systems that can be down or fail.
There we want to manually restart the workflow from failed point.

22

Have you considered just retrying activities indefinitely while these third party systems are down?

This way you don’t need manual restarts at all.

23

for some recoverable error , we can go for retries but if failure happens due to bad data , this will keep failing forever.
the user base which we are targeting is in millions by next year, so not sure how efficient retries would be.
Also in some of our use cases we are using Kafka for getting the events.

24

for some recoverable error , we can go for retries but if failure happens due to bad data , this will keep failing forever.

I see. In this case, fixing the workflow code and reset is the right way to go.

the user base which we are targeting is in millions by next year, so not sure how efficient retries would be.

This shouldn’t be a problem as you can rate control activity executions.

Also in some of our use cases we are using Kafka for getting the events.

So in this case do you reset workflow to the state before getting the event?

25

I tried resetting like this:
ResetWorkflowExecutionRequest request = ResetWorkflowExecutionRequest.newBuilder().setNamespace(namespace)
.setWorkflowExecution(WorkflowExecution.newBuilder().setWorkflowId(workflowId).build())
.setWorkflowTaskFinishEventId(tid)
.setReason(“reset”)
.build();

where in I was looking for last task id from temporal -dashboard and then passing it, how can i get this task finish event id programmatically ?

Also,
say my activity method is :

void hello(){
         System.out.println("test 3");
         throw new RuntimeException("test failed");
    }

even when I retsart this activity , the print statement doesn’t execute, activities are stateless so the entire activity method would be executed , right?

26

where in I was looking for last task id from temporal -dashboard and then passing it, how can i get this task finish event id programmatically ?

At this point, the best approach is to load the workflow execution history using GetWorkflowExecution gRPC API and find the last WorkflowTaskStarted event before the activity failure.

even when I retsart this activity , the print statement doesn’t execute, activities are stateless so the entire activity method would be executed , right?

This is weird. The whole activity should be reexecuted.

27

is it not part of java sdk?

28 
    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();

    GetWorkflowExecutionHistoryResponse result =
        service
            .blockingStub()
            .getWorkflowExecutionHistory(
                GetWorkflowExecutionHistoryRequest.newBuilder()
                    .setNamespace(namespace)
                    .setExecution(WorkflowExecution.newBuilder().setWorkflowId(workflowId).build())
                    .build());

Note that history can contain multiple pages. So you might need to call this API a few times using a page token.

1 Like
29

Thanks a lot @maxim , it is really helpful

30

Hi @maxim,
I logged all the events from history , here is the list:-
which Id should be set in .setWorkflowTaskFinishEventId( tid ) to restart from failed activity ?

Events :: id 1 type : EVENT_TYPE_WORKFLOW_EXECUTION_STARTED
Events :: id 2 type : EVENT_TYPE_WORKFLOW_TASK_SCHEDULED
Events :: id 3 type : EVENT_TYPE_WORKFLOW_TASK_STARTED
Events :: id 4 type : EVENT_TYPE_WORKFLOW_TASK_COMPLETED
Events :: id 5 type : EVENT_TYPE_ACTIVITY_TASK_SCHEDULED
Events :: id 6 type : EVENT_TYPE_ACTIVITY_TASK_STARTED
Events :: id 7 type : EVENT_TYPE_ACTIVITY_TASK_FAILED
Events :: id 8 type : EVENT_TYPE_WORKFLOW_TASK_SCHEDULED
Events :: id 9 type : EVENT_TYPE_WORKFLOW_TASK_STARTED
Events :: id 10 type : EVENT_TYPE_WORKFLOW_TASK_COMPLETED
Events :: id 11 type : EVENT_TYPE_WORKFLOW_EXECUTION_FAILED

31

Events :: id 3 type : EVENT

1 Like
33

Thanks @maxim , tried this way and it worked

 for (HistoryEvent e :  history.getEventsList()){
           //TODO : paginated history events list
           if(e.getEventType() == EventType.EVENT_TYPE_ACTIVITY_TASK_FAILED)
               break;
           if(e.getEventType() == EventType.EVENT_TYPE_WORKFLOW_TASK_STARTED)
               tid = e.getEventId();
       }

is it the correct way?

34

I think it should work

1 Like
35

are you able to resume the same workflow from failed point again and again?
For me I can do it just once.
Code i am referring is

GetWorkflowExecutionHistoryResponse result =
        service
            .blockingStub()
            .getWorkflowExecutionHistory(
                GetWorkflowExecutionHistoryRequest.newBuilder()
                    .setNamespace(namespace)
                    .setExecution(WorkflowExecution.newBuilder().setWorkflowId(workflowId).build())
                    .build());
36

Do you mean the issue about resetting more than once?
If so yes, you need to set an unique request id with each ResetWorkflowExecution request, for example:

ResetWorkflowExecutionRequest resetWorkflowExecutionRequest =
                ResetWorkflowExecutionRequest.newBuilder()
                        .setRequestId(UUID.randomUUID().toString())
                        .setNamespace("default")
                        .setWorkflowExecution(existingUntyped.getExecution())
                        .setWorkflowTaskFinishEventId(taskFinishEventId)
                        .build();
37

Thanks @tihomir , when I added requestId ,it solved my issue . I could see a new workflow instance.

  • How do we get existingUntyped.getexecution ()?
  • while restting some of the worlflows are getting timedout with cause - WORKFLOW_TASK_FAILED_CAUSE_RESET_WORKFLOW
38
  • How do we get existingUntyped.getexecution ()?

You can get the untyped workflow stub:

  1. to an existing wokflow exec:
    WorkflowStub existingUntyped = client.newUntypedWorkflowStub(workflowId, Optional.of(runId), Optional.of(workflowType));
  2. From a typed stub:
MyWorkflow workflow = client.newWorkflowStub(
                MyWorkflow.class,
                WorkflowOptions.newBuilder()
                        .setWorkflowId(workflowId)
                        .setTaskQueue(taskQueue)
                        .build()
        );
        // ...
        WorkflowStub untypedWorkflowStub = WorkflowStub.fromTyped(workflow);
  • while restting some of the worlflows are getting timedout with cause - WORKFLOW_TASK_FAILED_CAUSE_RESET_WORKFLOW

I think all of them should have this after reset. Reset seems to time out the wft and continue execution from it again.

1 Like
39

Thanks @tihomir for your prompt response.

40

Hi, I’m now trying to use Temporal but got an error when using the method: resetWorkflowExecution

io.temporal.failure.ActivityFailure: scheduledEventId=35, startedEventId=36, activityType='WaitJenkins', activityId='3fea59fa-d703-39d5-8612-4491a62f2ac7', identity='1@zcp-console-dev-main-va1-meta-5f4f5fb684-q7cqs', retryState=RETRY_STATE_NON_RETRYABLE_FAILURE

Here is my code:

WorkflowServiceStubs svc = WorkflowServiceStubs.newConnectedServiceStubs(wfsOpts, Duration.ofSeconds(5));
ResetWorkflowExecutionRequest request = xxx;
temporalSvc.blockingStub().resetWorkflowExecution(request);

My Agenda:
Users can retry the failed workflow manually. Also, they can choose to pick up where they failed or start over.

Thanks!

41

Hi @Haiping_Yu just referencing same question here.