Как избежать ада обратного вызова с помощью asyncio в Python

У меня такая ситуация. У меня есть 3 службы JobInitiator, Mediator, Executor, которые разговаривают друг с другом следующим образом.

• JobInitiator один раз каждые X минут помещает в очередь (RabbitMQ) запрошенное задание.
• Служба Executor каждые Y минут отправляет вызов REST API службе Mediator и спрашивает, нужно ли выполнить какие-либо задания. Если это так - Mediator извлекает сообщение из очереди и возвращает сообщение службе Executor в ответе.
• После того, как Executor завершает выполнение задания, он отправляет результаты задания в API службы Mediator, которая публикует их в очереди, которую прослушивает JobInitiator.

Боковые примечания + ограничения и ограничения:

• Сервис Mediator - это просто оболочка REST API для моей очереди. Основная проблема заключается в том, что к сервису Executor нельзя получить доступ публично - разрешены только исходящие вызовы api.
• Не могу подключить очередь напрямую с JobInitiator к сервису Executor

До сих пор ничего особенного в этом процессе нет. Мне было интересно, можно ли написать это с помощью asyncio в python, чтобы я не имел дела с адом обратного вызова. Что-то вроде этого (псевдокод)

class JobInitiator(object):
    def do_job():
        token = await get_token()
        applicative_results = await get_results(token=token)

где get_token() и get_results() оба проходят процесс, описанный выше.