try run server and client in same task
This commit is contained in:
parent
bc3f6ac452
commit
f5394c142f
1 changed files with 3 additions and 3 deletions
|
@ -52,7 +52,7 @@ def create_matrix_client(config: Config) -> AsyncClient:
|
||||||
|
|
||||||
|
|
||||||
async def start_matrix_client(
|
async def start_matrix_client(
|
||||||
client: AsyncClient, cache: Cache, config: Config
|
client: AsyncClient, webhook_server: Webhook, cache: Cache, config: Config
|
||||||
) -> bool:
|
) -> bool:
|
||||||
# Keep trying to reconnect on failure (with some time in-between)
|
# Keep trying to reconnect on failure (with some time in-between)
|
||||||
while True:
|
while True:
|
||||||
|
@ -134,8 +134,8 @@ def main() -> None:
|
||||||
webhook_server = Webhook(client, cache, config)
|
webhook_server = Webhook(client, cache, config)
|
||||||
|
|
||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
loop.create_task(webhook_server.start())
|
# loop.create_task(webhook_server.start())
|
||||||
loop.create_task(start_matrix_client(client, cache, config))
|
loop.create_task(start_matrix_client(client, webhook_server, cache, config))
|
||||||
|
|
||||||
try:
|
try:
|
||||||
loop.run_forever()
|
loop.run_forever()
|
||||||
|
|
Loading…
Reference in a new issue