From 06822c019747055720d967a620494cf08999a3f8 Mon Sep 17 00:00:00 2001 From: koalasat Date: Wed, 7 Aug 2024 10:13:48 +0200 Subject: [PATCH] Async to sync --- api/tasks.py | 4 ++-- requirements.txt | 1 + tests/utils/trade.py | 3 +-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/api/tasks.py b/api/tasks.py index 824bd9e69..416a58475 100644 --- a/api/tasks.py +++ b/api/tasks.py @@ -1,4 +1,4 @@ -import asyncio +from asgiref.sync import async_to_sync from celery import shared_task from celery.exceptions import SoftTimeLimitExceeded @@ -261,7 +261,7 @@ def nostr_send_order_event(order_id=None): order = Order.objects.get(id=order_id) nostr = Nostr() - asyncio.run(nostr.send_order_event(order)) + async_to_sync(nostr.send_order_event)(order) return diff --git a/requirements.txt b/requirements.txt index 92f1f8a4c..51334cc34 100644 --- a/requirements.txt +++ b/requirements.txt @@ -30,3 +30,4 @@ django-cors-headers==4.4.0 base91==1.0.1 nostr-sdk==0.32.2 pygeohash==1.2.0 +asgiref == 3.8.1 diff --git a/tests/utils/trade.py b/tests/utils/trade.py index c6303b0ad..39bcda0a1 100644 --- a/tests/utils/trade.py +++ b/tests/utils/trade.py @@ -5,7 +5,7 @@ from api.management.commands.clean_orders import Command as CleanOrders from api.management.commands.follow_invoices import Command as FollowInvoices from api.models import Order -from api.tasks import follow_send_payment, send_notification, nostr_send_order_event +from api.tasks import follow_send_payment, send_notification from tests.utils.node import ( add_invoice, create_address, @@ -156,7 +156,6 @@ def process_payouts(self, mine_a_block=False): wait_nodes_sync() @patch("api.tasks.send_notification.delay", send_notification) - @patch("api.tasks.nostr_send_order_event.delay", nostr_send_order_event) def publish_order(self): # Maker's first order fetch. Should trigger maker bond hold invoice generation. self.get_order()