Update workflow_invocation.py

workflow_invocation.py

@@ -18,14 +18,26 @@ class WorkflowInvocation:
     async def invoke_workflow(self): 
         try:   
             webHookUrl = self.config['workflow']['webhook_url']   
-            print(webHookUrl)
+            #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
+                try:
+                # Try to parse JSON response
+                    json_response = response.json()
+                    print("JSON Response:", json_response)
+                    return json_response
+                except Exception as e:
+                # Fall back to raw text
+                    print("Non-JSON response:", response.text)
+                    return response.text               
                 #print("Response status code:", response.json())
+        except httpx.RequestError as e:
+            print(f"Request error occurred: {e}")
+        except httpx.HTTPStatusError as e:
+            print(f"HTTP error occurred: {e.response.status_code} - {e.response.text}")
         except Exception as e:
-            print(f"An error occurred: {e}")  
+            import traceback
+            print("Unexpected error:", str(e))
+            traceback.print_exc()