@@ -311,6 +311,8 @@ class ArbitrageProcess:
logger.error(msg)
add_state_flow_entry(self.process_item, self.current_state, msg, "fail")
+ self._set_state(self.STATE_FAILED)
+
return
# 查询交易所订单状态