"į", "iki", "ir", "iš", "ja", "ją", "jai", "jais", "jam", "jame", "jas", "jei", "ji", "jį", "jie", "jiedu", "jiedvi", "jiedviem", "jiedviese", "jiems", "jis", "jo", "jodviem", "jog", "joje", "jomis", "joms", "jos", "jose", "jų", "judu", "judvi", "judviejų", "jųdviejų", "judviem", "judviese", "jumis", "jums", "jumyse", "juo", "juodu", "juodviese", "juos", "juose", "jus", "jūs", "jūsų", "ką", "kad", "kai", "kaip", "kas", "kiek", "kol", "kur", "kurie", "kuris", "man", "mane", "manęs", "manimi", "mano",...

    /**
     * The Fess configuration.
     */
    @Resource
    protected FessConfig fessConfig;

    /**
     * Gets a list of scheduled jobs based on the pager.
     * @param scheduledJobPager The pager for scheduled jobs.
     * @return A list of scheduled jobs.
     */
    public List<ScheduledJob> getScheduledJobList(final SchedulerPager scheduledJobPager) {

        jobLogBhv.queryDelete(cb -> {
            cb.query().setJobStatus_InScope(jobStatusList);
        });
    }

    /**
     * Updates the status of expired jobs that haven't finished.
     * Jobs that have been running longer than the expired job interval
     * without an end time are marked as failed.
     */
    public void updateStatus() {

import org.lastaflute.job.LaJob;
import org.lastaflute.job.LaJobRunner;
import org.lastaflute.job.LaJobScheduler;

import jakarta.annotation.Resource;

/**
 * Job scheduler for managing all scheduled jobs in Fess.
 * Implements LaJobScheduler to handle job scheduling and execution.
 */
public class AllJobScheduler implements LaJobScheduler {

    private static final Logger logger = LogManager.getLogger(AllJobScheduler.class);

    /** Service for managing scheduled jobs */
    @Resource
    private ScheduledJobService scheduledJobService;
    /** Pager for paginating scheduled job results */
    @Resource
    private SchedulerPager schedulerPager;
    /** Helper for processing scheduled jobs. */
    @Resource
    protected ProcessHelper processHelper;

  pull_request:
    types: [opened, labeled, unlabeled, synchronize]

permissions:
  contents: read

env:
  GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false"

jobs:
  test_docs:
    permissions:
      checks: write # for actions/upload-artifact
    runs-on: ubuntu-latest
    if: github.ref == 'refs/heads/master' || contains(github.event.pull_request.labels.*.name, 'documentation')

  pull_request:
    types: [opened, labeled, unlabeled, synchronize]

permissions:
  contents: read

env:
  GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false"

jobs:
  test_containers:
    permissions:
      checks: write # for actions/upload-artifact
    runs-on: ubuntu-latest
    if: github.ref == 'refs/heads/master' || contains(github.event.pull_request.labels.*.name, 'containers')

        // Setup test with mock ScheduledJobBhv
        final AtomicInteger callCount = new AtomicInteger(0);
        final List<ScheduledJob> scheduledJobs = new ArrayList<>();

        // Create test scheduled jobs
        ScheduledJob job1 = new ScheduledJob() {
            @Override
            public String getId() {
                return "job1";
            }

            @Override

          thrownAtomicReferenceFieldUpdaterFailure = atomicReferenceFieldUpdaterFailure;
          helper = new SynchronizedHelper();
        }
      }
    } else {
      /*
       * We avoid Unsafe, since newer JVMs produce warnings or even errors for attempts to use it.
       *
       * In guava-jre, we avoid Unsafe by using VarHandle instead. But if we have references to

name: Java CI with Maven

on:
  push:
    branches:
    - master
    - "*.x"
  pull_request:
    branches:
    - master
    - "*.x"

jobs:
  build:

    runs-on: ubuntu-latest

    steps:
    - uses: actions/checkout@v2
    - name: Set up JDK 21
      uses: actions/setup-java@v2
      with:
        java-version: '21'