How to properly handle exception raise in a AsyncIOScheduler job ?

[Olybo]

Hello,

I'm trying to understand how to properly handle exceptions that occur in a job.

The following code simulates an asynchronous job that occasionally raises an exception.
When the job fails, a callback runs to simulate post-failure actions.

import asyncio
import random

from apscheduler.schedulers.asyncio import AsyncIOScheduler
from apscheduler.events import EVENT_JOB_ERROR

async def run_job(job_id) :
    rand_nb = random.randint(1, 10)

    #Simulate async execution code
    print(f"{job_id} : sleep {rand_nb*0.1}")
    await asyncio.sleep(rand_nb*0.1)

    # Simulate an exception
    if rand_nb%3==0:
        print(f"{job_id} : Error")
        raise ValueError(f"Job {job_id} : An error occur")
    else:
        print(f"{job_id} : Success")

def callback_job_fail(event):
        # Simulate code doing things when job has fail
        print(f'{event.job_id} raised {event.exception.__class__.__name__}')

def main():
    scheduler = AsyncIOScheduler()
    interval = 3
    try:
        scheduler.add_listener(callback_job_fail, EVENT_JOB_ERROR)
        scheduler.add_job(func=run_job,
                          trigger='interval',
                          id=f'My job',
                          seconds=interval,
                          args=["My job"])
        scheduler.start()

        asyncio.get_event_loop().run_forever()

    except KeyboardInterrupt:
        print("Shutdown scheduler...")
        scheduler.shutdown()
    except Exception :
        print("An exception was handle")

if __name__ == "__main__":
    main()

Here's an example of the output:

My job : sleep 0.5
My job : Success
My job : sleep 0.6000000000000001
My job : Error
My job raised ValueError
Job "run_job (trigger: interval[0:00:03], next run at: 2025-01-10 15:36:15 CET)" raised an exception
Traceback (most recent call last):
  File "[...].venv/lib/python3.13/site-packages/apscheduler/executors/base_py3.py", line 30, in run_coroutine_job
    retval = await job.func(*job.args, **job.kwargs)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "[...]", line 18, in run_job
    raise ValueError(f"Job {job_id} : An error occur")
ValueError: Job My job : An error occur
Shutdown scheduler...

As you can see, the exception is not handled and is displayed in the output.
However, if I change the code to handle the exception in the run_job function, the callback is not triggered.

How can I properly handle exceptions raised in an AsyncIOScheduler job to trigger the EVENT_JOB_ERROR event while avoiding the display of the traceback exception in the output?

Thank you in advance for your advice.