here is the code :

[Mhammouda]

here is the code that i use to exécurte :
my function in views.py :

def test1(serial_number_IAD):
    print("________________________________")
    print(datetime.now())
    print("I M test from ", serial_number_IAD)
    print("________________________________")`

@login_required(login_url='login')
@forCustomer
def rebootloop(request):
    try:
        if request.method == "GET":
            test_ap = AP.objects.filter(user=request.user.username)
            if len(test_ap) == 0:
                messages.warning(request, "ValueError : NO DEVICE ASSIGNED TO YOUR ACCOUNT")
            context = {'test_ap': test_ap}
            return render(request, 'reboot.html', context)
        if request.method == "POST":
            url = request.META.get('HTTP_REFERER')
            serial_number = request.POST.get('monselect')
            test_ap = AP.objects.get(serial_number=serial_number)

            if not test_ap:
                messages.error(request, "ValueError : NO DEVICE ASSIGNED TO YOUR ACCOUNT")
            else:
                last_test = Package.objects.filter(
                    Q(serial_nmber=serial_number) & (Q(status='wait') | Q(status='IN_PROGRESS')))
                if len(last_test) != 0:
                    messages.warning(request, "ValueError : test is already in progress.")
                    return render(request, 'reboot.html')
                else:
                    day = request.POST.get('day')
                    timee = request.POST.get('time')

                    range = (request.POST.get('range'))
                    if range == "" or day == "" or timee == "":
                        messages.error(request, "ValueError :Please complete all fields")
                    else:

                        if test_ap.status == "NOT_CONNECTED":
                            messages.error(request, "ValueError :you cannot run a test on  device Not_Connected")
                        else:

                            range = int(request.POST.get('range'))
                            next_run_time = str(day) + " " + str(timee) + ":00"
                            test_ap.test = "TEST_IN_PROCESSING"
                            test_ap.save()
                            serial_number = test_ap.serial_number
                            current_soft = test_ap.Soft_C0

                            task_id = serial_number + str(next_run_time).replace(".", "").replace("+", "-").replace(":",
                                                                                                                    "-")

                            if range < 1:
                                messages.error(request, "the range of task must be greater than 1")
                            else:
                                try:
                                    logger.info("Starting scheduler...")
                                    scheduler = BackgroundScheduler()
                                    scheduler.add_jobstore(DjangoJobStore(), "default")
                                    time_task = range
                                    scheduler.add_job(

                                        test1, IntervalTrigger(minutes=range),  # Every 10 seconds
                                        id=task_id,  # The `id` assigned to each job MUST be unique
                                        max_instances=100, next_run_time=next_run_time,
                                        replace_existing=False,
                                        args=[serial_number]
                                    )
                                    logger.info("Added job 'my_job'.")
                                    scheduler.start()
                                    messages.success(request, "TASK LANCE")
                                except KeyboardInterrupt:
                                    logger.info("Stopping scheduler...")
                                    scheduler.shutdown()
                                    logger.info("Scheduler shut down successfully!")

                                job = scheduler.get_job(job_id=task_id)

                                filename = "log" + str(serial_number) + str(next_run_time).replace(".", "").replace("+",
                                                                                                                    "-").replace(
                                    ":", "-")

                                b = LOG(serial_nmber=serial_number, taskid=task_id, filename=filename,
                                        user=request.user.username, name_job=job, name=job.name, triger=job.trigger,
                                        time_job=job.next_run_time, nbr_RES=0, nbr_reboot=0, current_soft=current_soft)
                                b.save()

            context = {}
            return redirect(url)

    except:
        messages.error(request, "Pas de Serial pour ce compte")
        return render(request, 'reboot.html')

the result is :

________________________________
________________________________
2023-08-27 14:20:00.008855
2023-08-27 14:20:00.010853
I M test from --->  12725321740837911
I M test from --->  12725321740837911
________________________________
________________________________
________________________________
________________________________
2023-08-27 14:21:00.011052
I M test from --->  127253217sdf40837d9qsd
2023-08-27 14:21:00.013046
I M test from --->  127253217sdf40837d9qsd
________________________________
________________________________
________________________________
2023-08-27 14:22:00.020459
I M test from --->  12725321740837911
________________________________
________________________________
2023-08-27 14:22:00.023033
I M test from --->  12725321740837911
________________________________

Originally posted by @Mhammouda in #592 (reply in thread)

[agronholm]

Next time, don't open an issue unless you are prepare to make a bug report. I also fixed your formatting. Code blocks start and end with three backticks.

[agronholm]

So looking at the code, you create and start a new scheduler every time you get a POST request to the /login endpoint? Am I correct? Why do you need multiple schedulers running? Don't you want to just start one scheduler at the beginning and use that?
Also, have you considered what happens if you have multiple workers? Finally, I asked you to look at the FAQ, and you said you didn't find anything there relevant to your situation? Even the fact that you're sharing a persistent job store among multiple schedulers? Which is something that doesn't work properly on APScheduler 3.

[Mhammouda]

yes, exactly
In fact , this is a platform multi-user and each user can launch a scheduled job by launching a request post not to /login but to rebootloop end point (the decorator login required @login_required(login_url='login') is just to say that this function is only accessible if the user is logged in )

[agronholm]

That doesn't explain why you're running multiple schedulers, or why you thought that the FAQ entry I linked doesn't apply to your use case.

[Mhammouda]

ok, I will try the workaround mentioned in the section in the URL How do I share a single job store among one or more worker processes?

[agronholm]

Just FYI, APScheduler 4.0 supports shared job stores, but it's still in alpha and not recommended for production yet. But even then, you should only run a single scheduler within each worker.