Getting "Requested bean is currently in creation: Is there an unresolvable circular reference?" when task is calling another sub-task in Spring Boot

[onurhb]

I have created following Spring service that schedules a task:

@Service
class NewApplicationRoutingTaskScheduler(
     private val schedulerClient: SchedulerClient,
    @Qualifier("newApplicationTask") private val newApplicationTask: OneTimeTask<NewApplicationTaskPayload>,
) {
    fun createTask( ) {
        schedulerClient.schedule(
            newApplicationTask.instance(...),
            Instant.now(),
        )
    }
}

Here is the task configuration:

@Configuration
open class NewApplicationRoutingTaskConfiguration(
    private val lpSakService: LpSakService,
) {
    @Bean("newApplicationTask")
    open fun newApplicationTask(): OneTimeTask<NewApplicationTaskPayload> {
        return Tasks.oneTime("newApplicationTask", NewApplicationTaskPayload::class.java)
            .onFailure(...  )
            .execute { _, _ ->
                 lpSakService.opprettLpSakFraSøknad(...)
            }
    }
}

However, LpSakService is relied on another service MailService which is also using db-scheduler for handling e-posts.

@Service
class MailService(
    private val schedulerClient: SchedulerClient,
    @Qualifier("mail-task") private val mailTask: OneTimeTask<ScheduledMailPayload>,
) { ... }

In this scenario, NewApplicationRoutingTaskScheduler depends on Scheduler, and LpSakService itself has a subordinate dependency, MailService, which in turn relies on Scheduler. Notably, there seems to be no explicit circular reference in this configuration.

My conjecture is that the issue lies in the fact that the Scheduler is awaiting database availability, causing a delay in its instantiation. Consequently, this delay triggers the error message: "Requested bean is currently in creation: Is there an unresolvable circular reference?".

I am using @Lazy to solve this. Are there alternative methods that could be considered? Am I doing something wrong?

[kagkarlsson]

Hi! I can schedule new instances of tasks without a reference to the task. See for example LongRunningJobConfiguration.java

  public static final TaskWithDataDescriptor<PrimeGeneratorState> LONG_RUNNING_TASK =
      new TaskWithDataDescriptor<>("long-running-task", PrimeGeneratorState.class);

...
LONG_RUNNING_TASK.instance("prime-generator", initialState), Instant.now() ...
...

[onurhb]

Thanks for quick reply. I tried this method like following:

@Service
class NewApplicationRoutingTaskScheduler(
    private val schedulerClient: SchedulerClient
) {
    val NEW_APPLICATION_TASK: TaskWithDataDescriptor<NewApplicationTaskPayload> =
        TaskWithDataDescriptor("newApplicationTask", NewApplicationTaskPayload::class.java)

    fun createTask() {
        schedulerClient.schedule(
            NEW_APPLICATION_TASK.instance(
                søknad.application.id.toString(),
                NewApplicationTaskPayload(søknad, bankIds, correlationId),
            ),
            Instant.now(),
        )
    }
}

@Configuration
open class NewApplicationRoutingTaskConfiguration(
    private val lpSakService: LpSakService,
) {
    @Bean("newApplicationTask")
    open fun newApplicationTask(): OneTimeTask<NewApplicationTaskPayload> {
        return Tasks.oneTime("newApplicationTask", NewApplicationTaskPayload::class.java)
            .onFailure( )
            .execute { inst, _ ->
               ...
            }
    }
}

I am still getting the same error.
I don't understand how this can solve the issue as Spring will still try to create LpSakService?