Skip to content

Commit 5086877

Browse files
committed
Add new Python async files and classes
1 parent 8358173 commit 5086877

File tree

4 files changed

+49
-0
lines changed

4 files changed

+49
-0
lines changed

demo/python/async/bo.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
from grongier.pex import BusinessOperation
2+
from msg import MyMessage
3+
4+
import time
5+
6+
class MyBO(BusinessOperation):
7+
def on_message(self, request):
8+
print(f"Received message: {request.message}")
9+
time.sleep(1)
10+
return MyMessage(message=f"Hello, {request.message}")
11+
12+

demo/python/async/bp.py

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
from grongier.pex import BusinessProcess
2+
from msg import MyMessage
3+
4+
5+
class MyBP(BusinessProcess):
6+
7+
def on_message(self, request):
8+
msg_one = MyMessage(message="Message1")
9+
msg_two = MyMessage(message="Message2")
10+
11+
self.send_request_async("Python.MyBO", msg_one,completion_key="1")
12+
self.send_request_async("Python.MyBO", msg_two,completion_key="2")
13+
14+
def on_response(self, request, response, call_request, call_response, completion_key):
15+
if completion_key == "1":
16+
self.response_one = call_response
17+
elif completion_key == "2":
18+
self.response_two = call_response
19+
20+
def on_complete(self, request, response):
21+
self.log_info(f"Received response one: {self.response_one.message}")
22+
self.log_info(f"Received response two: {self.response_two.message}")
23+
24+

demo/python/async/msg.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
from grongier.pex import Message
2+
from dataclasses import dataclass
3+
4+
@dataclass
5+
class MyMessage(Message):
6+
message : str = None

demo/python/async/settings.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
from bo import MyBO
2+
from bp import MyBP
3+
4+
CLASSES = {
5+
"Python.MyBO": MyBO,
6+
"Python.MyBP": MyBP,
7+
}

0 commit comments

Comments
 (0)