perf(tradein): cian full-load incremental save + concurrent pagination #929
1 changed files with 0 additions and 1 deletions
|
|
@ -1703,7 +1703,6 @@ async def run_cian_full_load(
|
||||||
except RuntimeError as exc:
|
except RuntimeError as exc:
|
||||||
# on_bucket кидает RuntimeError("cancelled") при cooperative cancel
|
# on_bucket кидает RuntimeError("cancelled") при cooperative cancel
|
||||||
if str(exc) == "cancelled":
|
if str(exc) == "cancelled":
|
||||||
_cancelled = True
|
|
||||||
logger.info(
|
logger.info(
|
||||||
"cian-full-load run_id=%d: cancelled — partial results unique=%d ins=%d upd=%d",
|
"cian-full-load run_id=%d: cancelled — partial results unique=%d ins=%d upd=%d",
|
||||||
run_id,
|
run_id,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue