Я попробовал следующий код, упомянутый в приложении Faust Документация . Когда я запускаю 4 параллельных приложения, я получаю журналы, в которых говорится, что одно из них выбрано лидером. Но код, упомянутый в функции, не выполняется. Он застрял на нем, и я не вижу выполнения какого-либо оператора.
@app.timer(2.0, on_leader=True)
async def publish_greetings():
print('PUBLISHING ON LEADER!')