loop

Author: SempaiEcchi

bpmn_types.py

@@ -23,8 +23,9 @@
 
 BPMN_MAPPINGS = {}
 
+timeout = ClientTimeout(sock_connect=5)
+client_session = ClientSession(timeout=timeout)
 
-client_session = ClientSession(loop=asyncio.get_event_loop(),timeout=ClientTimeout(sock_connect=5))
 
 def bpmn_tag(tag):
     def wrap(object):
@@ -253,7 +254,13 @@ async def run_connector(self, variables, instance_id):
         )
 
         # Check method and make request
-
+        async with aiohttp.ClientSession() as session:
+            async with session.get('http://httpbin.org/get') as resp:
+                print(resp.status)
+                print(await resp.text())
+        print(await resp.text())
+        print("test")
+        return
         if method := self.connector_fields["input_variables"].get("method") or "GET":
             if method == "POST":
                 call_function = client_session.post

server.py

@@ -4,7 +4,7 @@
 import os
 from uuid import uuid4
 import asyncio
-from aiohttp import web
+from aiohttp import web, ClientSession, ClientTimeout
 
 from aiohttp.web_ws import WebSocketResponse
 
@@ -88,7 +88,7 @@ async def handle_new_instance(request):
 
 @routes.get("/model/{model_name}/instance")
 async def handle_new_instance(request):
-    _id = str(uuid4())+str(uuid.uuid1())
+    _id = str(uuid4()) + str(uuid.uuid1())
 
     model = request.match_info.get("model_name")
     instance = await app["bpmn_models"][model].create_instance(_id, {})
@@ -237,10 +237,8 @@ async def handle_instance_state(request):
 app = None
 
 
-
 async def run():
     global app
-
     app = web.Application()
     app.on_startup.append(run_as_server)
     app.add_routes(routes)