Python: как заставить асинхронный генератор ожидать вызова другой функции

Question

Я работаю с Django и Graphql, используя Ariadne(новую библиотеку python graphql, которая поддерживает подписки с использованием каналов) и каналы Django. Я хочу подписаться на изменения в модели, которые можно сделать с помощью сигналов Django, но я не могу связать их вместе.

Моя функция приемника сигнала:

@receiver(post_save, sender=get_user_model())
def user_handler(sender, instance, **kwargs):
   print("======> Signal Called")
   return instance

Мои обработчики подписки:

@subscription.source("counter")
async def counter_generator(obj, info):
    user = await this_needs_to_be_implemented()
    yield user


@subscription.field("counter")
def counter_resolver(count, info):
    print("count ====> ", count)
    return count + 1

Примечание: генератор счетчиков является асинхронной функцией.