Планировщик кита передаёт регион из строки расписания в обход #3515
1 changed files with 4 additions and 0 deletions
|
|
@ -39,6 +39,9 @@ from scraper_kit.orchestration.scheduler import (
|
||||||
from scraper_kit.orchestration.scheduler import (
|
from scraper_kit.orchestration.scheduler import (
|
||||||
_pick_resume as kit_pick_resume,
|
_pick_resume as kit_pick_resume,
|
||||||
)
|
)
|
||||||
|
from scraper_kit.orchestration.scheduler import (
|
||||||
|
_resolve_region_code as kit_resolve_region_code,
|
||||||
|
)
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from scraper_kit.orchestration.scheduler import SchedulerContext
|
from scraper_kit.orchestration.scheduler import SchedulerContext
|
||||||
|
|
@ -515,6 +518,7 @@ async def _job_domclick_city_sweep(
|
||||||
rooms=params.get("rooms"),
|
rooms=params.get("rooms"),
|
||||||
pages=int(params.get("pages_per_anchor", 5)),
|
pages=int(params.get("pages_per_anchor", 5)),
|
||||||
request_delay_sec=float(params.get("request_delay_sec", 6.0)),
|
request_delay_sec=float(params.get("request_delay_sec", 6.0)),
|
||||||
|
region_code=kit_resolve_region_code(params),
|
||||||
resume_run_id=kit_pick_resume(db, run_id),
|
resume_run_id=kit_pick_resume(db, run_id),
|
||||||
cookies=cookies,
|
cookies=cookies,
|
||||||
)
|
)
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue