Skip to content

Cancelation of Local Activities #1303

@GeekNickson

Description

@GeekNickson

Expected Behavior

I have a bunch of local activities with retry options configured that are being ran inside a cancellation scope like so:

val scope = Workflow.newCancellationScope { _ -> 
  activity1.execute()
  ....
  activityN.execute()
}
Workflow.newTimer(Duration.ofSeconds(10))
  .thenApply { scope.cancel() }

scope.run()

I expected that when scope.cancel() method is called that would close the scope with the running activities just as it works with normal activities.

Actual Behavior

Activities proceed to retry, the code after scope.run() doesn't execute

Specifications

  • Version: 1.13.0
  • Platform: Java

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions