public void updateLockedJobTriggers() {
        final DateTime now = clock.nowUTC();
        final var filter = and(
                eq(FIELD_LOCK_OWNER, nodeId),
                eq(FIELD_STATUS, JobTriggerStatus.RUNNING)
        );
        collection.updateMany(filter, set(FIELD_LAST_LOCK_TIME, now));
    }
@Test
    @MongoDBFixtures("locked-job-triggers.json")
    public void updateLockedJobTriggers() {
        DateTime newLockTime = DateTime.parse("2019-01-01T02:00:00.000Z");
        final JobSchedulerTestClock clock = new JobSchedulerTestClock(newLockTime);
        final DBJobTriggerService service = serviceWithClock(clock);

        service.updateLockedJobTriggers();

        List<String> updatedJobTriggerIds = service.all().stream()
                .filter(jobTriggerDto -> newLockTime.equals(jobTriggerDto.lock().lastLockTime()))
                .map(JobTriggerDto::id)
                .collect(Collectors.toList());
        assertThat(updatedJobTriggerIds).containsOnly("54e3deadbeefdeadbeef0001", "54e3deadbeefdeadbeef0002");
    }