# Idiomatic way to update lock expiry time for ACT\_RU\_JOB **URL:** \ **Category:** Flowable Engine\ **Created:** [August 25, 2022, 3:56pm UTC](https://forum.flowable.org/t/idiomatic-way-to-update-lock-expiry-time-for-act-ru-job/9679 "2022-08-25T15:56:27Z")\ **Posts on this page:** 5\ **Page:** 1
**Author:** ![valb3r](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/valb3r/32/2155_2.png) [@valb3r](https://forum.flowable.org/u/valb3r)\ **Post date:** [August 25, 2022, 3:56pm UTC](https://forum.flowable.org/t/idiomatic-way-to-update-lock-expiry-time-for-act-ru-job/9679/1 "2022-08-25T15:56:27Z")
I have long running process wrapped in the async ServiceTask (2 hours+) as I’m trying to use Flowable as batch process orchestrator. The problem is I don’t want to change `flowable.process.async.executor.async-job-lock-time` default value (actually I want to have it lower, i.e. 10 minutes) because it affects for how long the process will be stuck if executor goes down abruptly - I don’t want worker to wait 2 hours doing nothing because of the lock. Is there an **idiomatic** way to update ACT\_RU\_JOB lock\_expiry\_time from ServiceTask code? I want to update the lock time i.e. each 1 minute, so that I can use small value of `async-job-lock-time` by simply updating lock lease time myself. Or even, maybe as a feature - it would be great if flowable updated that lock\_time itself if ServiceTask thread is still alive ---
**Author:** ![joram](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/joram/32/26_2.png) [@joram](https://forum.flowable.org/u/joram)\ **Post date:** [September 8, 2022, 4:26pm UTC](https://forum.flowable.org/t/idiomatic-way-to-update-lock-expiry-time-for-act-ru-job/9679/2 "2022-09-08T16:26:27Z")
> [@valb3r](#): > > I have long running process wrapped in the async ServiceTask (2 hours+) as I’m trying to use Flowable as batch process orchestrator. If the logic is so-long running, a service task is probably not the right approach (keeping a db transaction open that long isn’t a good idea). A better approach might be using an external worker task: [BPMN 2.0 Constructs · Flowable Open Source Documentation](https://www.flowable.com/open-source/docs/bpmn/ch07b-BPMN-Constructs/#external-worker-task) (which doesn’t keep anything on Flowable’s side open untildone). ---
**Author:** ![valb3r](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/valb3r/32/2155_2.png) [@valb3r](https://forum.flowable.org/u/valb3r)\ **Post date:** [September 11, 2022, 7:43am UTC](https://forum.flowable.org/t/idiomatic-way-to-update-lock-expiry-time-for-act-ru-job/9679/3 "2022-09-11T07:43:21Z")
@joram Thanks for reply, but same problem is present for ExternalWorkerJob - no way to update lock lease time in java interfaces ---
**Author:** ![MirekSz](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/mireksz/32/2112_2.png) [@MirekSz](https://forum.flowable.org/u/MirekSz)\ **Post date:** [September 13, 2022, 9:06am UTC](https://forum.flowable.org/t/idiomatic-way-to-update-lock-expiry-time-for-act-ru-job/9679/4 "2022-09-13T09:06:19Z")
We hade the same problem, `async-job-lock-time` indicates time when another engine could take task to execution in case of another(locking) engine dies/restarts. But what if this task simple takes longer… We solved this by starting thread with following code, too manualy increase exp\_time ```auto Thread thread = new Thread(() -> { while (true) { try { Thread.sleep(cfg.getAsyncExecutor().getAsyncJobLockTimeInMillis() / 2); try (Connection connection = dataSource.getConnection()) { try (PreparedStatement prepareStatement = connection.prepareStatement( "update act_ru_job set lock_exp_time_=? where lock_owner_=? and lock_exp_time_ is not null and create_time_ > lock_exp_time_ - interval '5' hour")) { LocalDateTime moveTime = LocalDateTime.now().plus(cfg.getAsyncExecutor().getAsyncJobLockTimeInMillis(), ChronoUnit.MILLIS); prepareStatement.setTimestamp(1, Timestamp.valueOf(moveTime)); prepareStatement.setString(2, cfg.getAsyncExecutor().getLockOwner()); prepareStatement.execute(); } } } catch (Exception e) { LOGGER.error(e.getMessage(), e); } } }); thread.setName("FlowableNextExpTimeMover"); thread.start(); ``` ---
**Author:** ![valb3r](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/valb3r/32/2155_2.png) [@valb3r](https://forum.flowable.org/u/valb3r)\ **Post date:** [September 13, 2022, 10:32am UTC](https://forum.flowable.org/t/idiomatic-way-to-update-lock-expiry-time-for-act-ru-job/9679/5 "2022-09-13T10:32:47Z")
@MirekSz thanks. I use similar solution via Springs’ scheduler ```auto @Scheduled(fixedDelayString = "\${flowable-executor.heartbeat.extend-schedule:PT1M}") @Transactional(propagation = Propagation.REQUIRES_NEW) fun extendLockLease() { val leaseTime = config.asyncExecutor.asyncJobLockTimeInMillis for (execId in activeExecutionsForHeartbeat) { logger.info { "Extending lease for $execId" } try { val jobs = manager.createJobQuery().executionId(execId).locked().list() jobs.forEach { val query = em.createNativeQuery("UPDATE act_ru_job SET lock_exp_time_ = ?2 WHERE id_= ?1 AND lock_exp_time_ IS NOT NULL") query.setParameter(1, it.id) val gregorianCalendar = GregorianCalendar() gregorianCalendar.time = config.clock.currentTime gregorianCalendar.add(Calendar.MILLISECOND, leaseTime) query.setParameter(2, gregorianCalendar.time, TemporalType.TIMESTAMP) query.executeUpdate() } logger.info { "Extended lease for $execId for ${leaseTime}ms" } } catch (ex: Throwable) { logger.error(ex) { "Failed updating lease for $execId" } } } } ``` But the point is (@joram ) there is no native way to update lock time… Locking for fixed amount of time is not ideal solution, update based on liveness would be better, at least for ExternalWorkerJob, as external workers can easily fail and locking something for long is bad idea