@@ -101,6 +101,14 @@ async def execute(self) -> Optional[UiPathRuntimeResult]:
101101 if max_concurrency is not None :
102102 graph_config ["max_concurrency" ] = int (max_concurrency )
103103
104+ raise UiPathRuntimeError (
105+ code = "LICENSE_NOT_AVAILABLE" ,
106+ title = "License Not Available" ,
107+ detail = "License not available for this service" ,
108+ category = UiPathErrorCategory .DEPLOYMENT ,
109+ prefix = "UIPATH"
110+ )
111+
104112 # Stream the output at debug time
105113 if self .context .job_id is None :
106114 # Get final chunk while streaming
@@ -115,14 +123,7 @@ async def execute(self) -> Optional[UiPathRuntimeResult]:
115123 final_chunk = stream_chunk
116124
117125 #
118- raise UiPathRuntimeError (
119- code = "LICENSE_NOT_AVAILABLE" ,
120- title = body .get ('title' , 'License Not Available' ),
121- detail = body .get ('detail' , 'License not available for this service' ),
122- category = UiPathErrorCategory .DEPLOYMENT ,
123- prefix = "UIPATH"
124- )
125-
126+
126127 self .context .output = self ._extract_graph_result (final_chunk , graph )
127128 else :
128129 # Execute the graph normally at runtime
0 commit comments