Scheduleモジュールでコルーチン関数を実行する方法

Question

前提・実現したいこと

discord.pyにてユーザー情報を格納しているjsonファイルを毎日0:00に更新し、
更新をユーザーに通知するボットを作っています。

該当のソースコード

import discord
from discord.ext import commands
import schedule
import datetime
import json

bt = None

async def update_cancell():
    global bt
    today = datetime.date.today()
    format_today = today.strftime(r"%Y-%m-%d")
    with open('user.json',mode="r") as f:
        user_data = json.load(f)
    cancell_list = [i for i in range(len(user_data["user"])) if user_data["user"][i]["cancell"] == format_today]
    official_logch = bt.get_channel(794125840531193886)
    official_ch = bt.get_channel(793704805570838540)
    if len(cancell_nt_list) != 0:
        for i in cancell_list:
            serverid = user_data["user"][i]["server_id"]
            server = bt.get_guild(serverid)
            await official_ch.send(f'契約が更新されなかったため契約を解消しました{serverid}')
            try:
                await server.system_channel.send('契約が更新されなかったため契約を解消しました')
                await server.owner.send('契約が更新されなかったため契約を解消しました')
            except:
                await official_logch.send(f'{serverid}に契約解消通知を送れませんでした。')
            else:
                await official_logch.send(f'{serverid}に契約解消通知を送りました')
            user_data["user"].pop(i)
        with open('user.json',mode="w") as f:
            json.dump(user_data,f,indent=4)
            

async def send_notice():
    global bt
    today = datetime.date.today()
    format_today = today.strftime(r"%Y-%m-%d")
    with open('user.json',mode="r") as f:
        user_data = json.load(f)
    cancell_nt_list = [i for i in range(len(user_data["user"])) if user_data["user"][i]["cancell_notice"] == format_today]
    if len(cancell_nt_list) != 0:
        official_logch = bt.get_channel(794125840531193886)
        official_ch = bt.get_channel(793704805570838540)
        for i in cancell_nt_list:
            serverid = user_data["user"][i]["server_id"]
            server = bt.get_guild(serverid)
            await official_ch.send(f'契約更新通知処理を実行しました{serverid}')
            try:
                await server.system_channel.send('**契約更新のお知らせです**\n契約解消まで残り3日となりました。\n更新する場合は`float#8394`までメッセージをください。')
                await server.owner.send('**契約更新のお知らせです**\n契約解消まで残り3日となりました。\n更新する場合は支払いの関係上`float#8394`までメッセージをください。')
            except:
                await official_logch.send(f'{serverid}に契約更新通知を送れませんでした。')
            else:
                await official_logch.send(f'{serverid}に契約更新通知を送りました')

class Connect_bot(commands.Cog):
    def __init__(self,bot):
        self.bot = bot






def setup(bot):
    global bt
    bot.add_cog(connect_bot(bot))
    bt = bot

#ここにmain関数を定義
#async def main


#コルーチン関数であるmainを実行したい。
schedule.every().day.at('0:00').do(main)

発生している問題・エラーメッセージ

scheduleモジュールではdoメソッドの引数に関数を指定して実行しますが、
コルーチン関数を実行する場合 await を付けなくてはいけないためどうすればいいか困っています。
実行可能な方法あるいは解決策等あればご教示ください。

Answer 1

asyncioを使って、コルーチンを同期処理で実行します。

import asyncio

# ~~~~~~~~~

def main():
    loop = asyncio.get_event_loop()
    loop.create_task(update_cancell())
    loop.create_task(send_notice())

これでコルーチンを実行することが出来ますが、コルーチンが終わる前に進んでしまうので注意してください。

import asyncio
loop = asyncio.get_event_loop()
async def coro():
    print("coro started")
    await asyncio.sleep(5)
    print("coro finished")
print("created task")
loop.create_task(coro())
print("after created task")

のようなコードを実行すると、

created task
after created task
coro started
coro finished

のようになります（この場合は別によさそうですが。）

また、tasks.loopを使う方法もありますが、詳しくは自分で調べてください。