|
|
@ -899,7 +899,18 @@ class BasicSwap(BaseApp): |
|
|
|
session = scoped_session(self.session_factory) |
|
|
|
session = scoped_session(self.session_factory) |
|
|
|
for bid in session.query(Bid): |
|
|
|
for bid in session.query(Bid): |
|
|
|
if bid.in_progress == 1 or (bid.state and bid.state > BidStates.BID_RECEIVED and bid.state < BidStates.SWAP_COMPLETED): |
|
|
|
if bid.in_progress == 1 or (bid.state and bid.state > BidStates.BID_RECEIVED and bid.state < BidStates.SWAP_COMPLETED): |
|
|
|
|
|
|
|
try: |
|
|
|
self.activateBid(session, bid) |
|
|
|
self.activateBid(session, bid) |
|
|
|
|
|
|
|
except Exception as ex: |
|
|
|
|
|
|
|
self.log.error('Failed to activate bid! Error: %s', str(ex)) |
|
|
|
|
|
|
|
if self.debug: |
|
|
|
|
|
|
|
self.log.error(traceback.format_exc()) |
|
|
|
|
|
|
|
try: |
|
|
|
|
|
|
|
self.deactivateBid(session, bid) |
|
|
|
|
|
|
|
except Exception as ex: |
|
|
|
|
|
|
|
self.log.error('Further error deactivating: %s', str(ex)) |
|
|
|
|
|
|
|
if self.debug: |
|
|
|
|
|
|
|
self.log.error(traceback.format_exc()) |
|
|
|
finally: |
|
|
|
finally: |
|
|
|
session.close() |
|
|
|
session.close() |
|
|
|
session.remove() |
|
|
|
session.remove() |
|
|
|