Update workflow_invocation.py

workflow_invocation.py

@@ -1,30 +1,31 @@
-from workflowschema import LibraryModel
-import httpx
-import asyncio
-import yaml
-
-
-class WorkflowInvocation:
-    def __init__(self, payload):
-        self.config = self.load_config()
-        self.payload = payload
-        
-    def load_config(self):
-        with open("config.yaml","r") as file:
-            config = yaml.safe_load(file)
-        return config
-
-    
-    async def invoke_workflow(self): 
-        try:   
-            webHookUrl = self.config['workflow']['webhook_url']   
-    
-            async with httpx.AsyncClient() as client:
-                response = await client.post(webHookUrl, json=self.payload)
-                response.raise_for_status()
-                json_response = response.json()
-                return json_response
-                #print("Response status code:", response.json())
-        except Exception as e:
-            print(f"An error occurred: {e}")  
-    
+from workflowschema import LibraryModel
+import httpx
+import asyncio
+import yaml
+
+
+class WorkflowInvocation:
+    def __init__(self, payload):
+        self.config = self.load_config()
+        self.payload = payload
+        
+    def load_config(self):
+        with open("config.yaml","r") as file:
+            config = yaml.safe_load(file)
+        return config
+
+    
+    async def invoke_workflow(self): 
+        try:   
+            webHookUrl = self.config['workflow']['webhook_url']   
+            print(webHookUrl)
+            async with httpx.AsyncClient() as client:
+                response = await client.post(webHookUrl, json=self.payload)
+                response.raise_for_status()
+                json_response = response.json()
+                print(json_response)
+                return json_response
+                #print("Response status code:", response.json())
+        except Exception as e:
+            print(f"An error occurred: {e}")  
+