Commit
·
ba71442
1
Parent(s):
b2c2f23
fixed paths
Browse files- listener.py +2 -2
- rabbit_base.py +1 -1
- rabbit_repo.py +4 -4
listener.py
CHANGED
|
@@ -1,8 +1,8 @@
|
|
| 1 |
import json
|
| 2 |
from typing import Callable, Dict, List, Optional
|
| 3 |
import aio_pika
|
| 4 |
-
from
|
| 5 |
-
from
|
| 6 |
|
| 7 |
# Maps FuncName -> handler coroutine
|
| 8 |
Handler = Callable[[dict], "awaitable[None]"]
|
|
|
|
| 1 |
import json
|
| 2 |
from typing import Callable, Dict, List, Optional
|
| 3 |
import aio_pika
|
| 4 |
+
from rabbit_base import RabbitBase
|
| 5 |
+
from config import settings
|
| 6 |
|
| 7 |
# Maps FuncName -> handler coroutine
|
| 8 |
Handler = Callable[[dict], "awaitable[None]"]
|
rabbit_base.py
CHANGED
|
@@ -1,7 +1,7 @@
|
|
| 1 |
import asyncio, json, uuid
|
| 2 |
import aio_pika
|
| 3 |
from typing import Callable, Dict, List, Optional
|
| 4 |
-
from
|
| 5 |
|
| 6 |
ExchangeResolver = Callable[[str], str] # exchangeName -> exchangeType
|
| 7 |
|
|
|
|
| 1 |
import asyncio, json, uuid
|
| 2 |
import aio_pika
|
| 3 |
from typing import Callable, Dict, List, Optional
|
| 4 |
+
from config import settings
|
| 5 |
|
| 6 |
ExchangeResolver = Callable[[str], str] # exchangeName -> exchangeType
|
| 7 |
|
rabbit_repo.py
CHANGED
|
@@ -1,9 +1,9 @@
|
|
| 1 |
import uuid
|
| 2 |
from typing import Any
|
| 3 |
-
from
|
| 4 |
-
from
|
| 5 |
-
from
|
| 6 |
-
from
|
| 7 |
|
| 8 |
class RabbitRepo(RabbitBase):
|
| 9 |
def __init__(self, external_source: str):
|
|
|
|
| 1 |
import uuid
|
| 2 |
from typing import Any
|
| 3 |
+
from rabbit_base import RabbitBase
|
| 4 |
+
from cloud_event import CloudEvent
|
| 5 |
+
from config import settings
|
| 6 |
+
from utils import to_json, json_compress_str
|
| 7 |
|
| 8 |
class RabbitRepo(RabbitBase):
|
| 9 |
def __init__(self, external_source: str):
|