loop

Author: SempaiEcchi

bpmn_types.py

@@ -24,7 +24,6 @@
 BPMN_MAPPINGS = {}
 
 timeout = ClientTimeout(sock_connect=5)
-client_session = ClientSession(timeout=timeout)
 
 
 def bpmn_tag(tag):
@@ -254,49 +253,52 @@ 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
-            elif method == "PATCH":
-                call_function = client_session.patch
-            else:
-                call_function = client_session.get
-            if not isinstance(data, dict):
-                data = dict(data)
-            response = await call_function(
-                url,
-                params=parameters,
-                json=data,
-                headers={'content-type': 'application/json'}
-            )
-            if response.status not in (200, 201):
-                raise Exception(response.text)
+        async with aiohttp.ClientSession(timeout=timeout) as client_session:
+            if method := self.connector_fields["input_variables"].get("method") or "GET":
+                if method == "POST":
+                    call_function = client_session.post
+                elif method == "PATCH":
+                    call_function = client_session.patch
+                else:
+                    call_function = client_session.get
+                if not isinstance(data, dict):
+                    data = dict(data)
+                response = await call_function(
+                    url,
+                    params=parameters,
+                    json=data,
+                    headers={'content-type': 'application/json'}
+                )
+                if response.status not in (200, 201):
+                    raise Exception(response.text)
+
+            r = {}
+            try:
+                r = await response.json()
+            except Exception as e:
+                print("error")
+                if not isinstance(e, ContentTypeError):
+                    raise e
+
+                # Check for output variables
+
+            if self.output_variables:
+                for key in self.output_variables:
+                    value = self.output_variables.get(key)
+                    if len(value) > 0:
+                        variables[key] = parse_expression(expression=value, process_variables=r)
+                    if key in r:
+                        variables[key] = r[key]
+            print(variables)
+        return r
+
+
+
+
+
 
-        r = {}
-        try:
-            r = await response.json()
-        except Exception as e:
-            print("error")
-            if not isinstance(e, ContentTypeError):
-                raise e
 
-            # Check for output variables
 
-        if self.output_variables:
-            for key in self.output_variables:
-                value = self.output_variables.get(key)
-                if len(value) > 0:
-                    variables[key] = parse_expression(expression=value, process_variables=r)
-                if key in r:
-                    variables[key] = r[key]
-        print(variables)
 
     async def run(self, variables, instance_id):