expose ExtendLock in task context

citilinkru · Oct 7, 2022 · 55ce926 · 55ce926
1 parent 4908fb1
commit 55ce926
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/processor/processor.go b/processor/processor.go
@@ -82,6 +82,14 @@ func (c *Context) Complete(query QueryComplete) error {
 	})
 }
 
+// Extend the lock for a new duration
+func (c *Context) ExtendLock(newDurationMS int) error {
+	return c.client.ExternalTask.ExtendLock(c.Task.Id, camundaclientgo.QueryExtendLock{
+		NewDuration: &newDurationMS,
+		WorkerId:    &c.Task.WorkerId,
+	})
+}
+
 // HandleBPMNError handle external task BPMN error
 func (c *Context) HandleBPMNError(query QueryHandleBPMNError) error {
 	return c.client.ExternalTask.HandleBPMNError(c.Task.Id, camundaclientgo.QueryHandleBPMNError{