Return current pool status for an account.
(self, account_id: str)
| 1117 | ) |
| 1118 | self.runtime_logs.finish_run( |
| 1119 | flow, |
| 1120 | status="success", |
| 1121 | message="完整支付链路执行成功", |
| 1122 | details={"biz_id": task.biz_id, "task_id": task.id, "amount": task.amount}, |
| 1123 | ) |
| 1124 | return task |
| 1125 | except RunPausedError as exc: |
| 1126 | self.runtime_logs.finish_run( |
| 1127 | flow, |
| 1128 | status="paused", |
| 1129 | message=str(exc), |
| 1130 | level=logging.WARNING, |
| 1131 | ) |
| 1132 | raise |
| 1133 | except Exception as exc: |
| 1134 | self.runtime_logs.finish_run( |
| 1135 | flow, |
| 1136 | status="failed", |
no test coverage detected