[safe run] if non from pool cf

Author: yellowbean

absbox/client.py

@@ -175,7 +175,7 @@ def __post_init__(self) -> None:
         else:
             self.url = isValidUrl(self.url).rstrip("/")
 
-        console.print(f" Connecting engine server -> {self.url}")
+        console.print(f"Connecting engine server -> {self.url}")
 
         if self.lang not in ["chinese", "english"]:
             raise AbsboxError(f"❌Invalid language:{self.lang}, only support 'chinese' or 'english' ")

absbox/local/cmp.py

@@ -71,3 +71,8 @@ def cmpMap(x:dict, y:dict) -> dict:
             comp_result['triggers'][locName] = cmpMap(r1['triggers'][locName], r2['triggers'][locName])
 
     return comp_result
+
+def compTwoEngine(xEngine, yEngine, d, pAssump, rAssump):
+    rx = xEngine.run(d, read=True, poolAssump=pAssump, runAssump=rAssump)
+    ry = xEngine.run(d, read=True, poolAssump=pAssump, runAssump=rAssump)
+    return compResult(rx, ry)

absbox/local/generic.py

@@ -146,7 +146,7 @@ def read(resp):
         elif deal_content['pool']['tag']=='MultiPool':
             poolMap = deal_content['pool']['contents']
             output['pool']['flow'] = tz.valmap(lambda v: readPoolCf(v['futureCf'][0]['contents']) if (not v['futureCf'] is None) else pd.DataFrame(), poolMap)
-            output['pool']['breakdown'] = tz.valmap(lambda v: list(tz.map(readPoolCf, v['futureCf'][1] & lens.Each()['contents'].collect() )) if (not v['futureCf'][1] is None) else [], poolMap)
+            output['pool']['breakdown'] = tz.valmap(lambda v: list(tz.map(readPoolCf, v['futureCf'][1] & lens.Each()['contents'].collect() )) if (v['futureCf'] and (not v['futureCf'][1] is None)) else [], poolMap)
         elif deal_content['pool']['tag']=='ResecDeal':
             poolMap = deal_content['pool']['contents']
             output['pool']['flow'] = {tz.get([1,2,4],k.split(":")): readPoolCf(v['futureCf']['contents']) for (k,v) in poolMap.items() }