Signal task_pre_run not working

[zikphil]

Hello,

If I make this signal function:

@task_prerun.connect
async def task_pre_run(task_id, task, args, **kwargs):
    print(task_id)

when I schedule a job it hangs forever at running this, I have to kill the celery process to restart