|
|
@@ -232,8 +232,8 @@ class ArbitrageProcess:
|
|
|
logger.info(msg)
|
|
|
add_state_flow_entry(self.process_item, self.current_state, msg, "success")
|
|
|
|
|
|
- # step4, 與賬戶eth餘額比對（至少留0.001,不然沒gas了）
|
|
|
- MARGIN = Decimal(0.001)
|
|
|
+ # step4, 與賬戶eth餘額比對（至少留0.002,不然沒gas了）
|
|
|
+ MARGIN = Decimal(0.002)
|
|
|
# 暫時鎖住core_data
|
|
|
with self.core_lock:
|
|
|
eth_balance = self.core_data['eth_balance']
|
|
|
@@ -430,8 +430,8 @@ class ArbitrageProcess:
|
|
|
logger.info(msg)
|
|
|
add_state_flow_entry(self.process_item, self.current_state, msg, "pending")
|
|
|
try:
|
|
|
- # 給300秒時間進行確認
|
|
|
- waiting_times = 300
|
|
|
+ # 給120秒時間進行確認
|
|
|
+ waiting_times = 120
|
|
|
while waiting_times > 0:
|
|
|
with self.pending_lock:
|
|
|
tx_details = copy.deepcopy(self.pending_data[chain_tx_hash]['tx_details'])
|
