ℹ️ About Codex in GitHub

\\n
\\n\\n[Your team has set up Codex to review pull requests in this repo](https://chatgpt.com/codex/cloud/settings/general). Reviews are triggered when you\\n- Open a pull request for review\\n- Mark a draft as ready\\n- Comment \\\"@codex review\\\".\\n\\nIf Codex has suggestions, it will comment; otherwise it will react with 👍.\\n\\n\\n\\n\\nCodex can also answer questions or update the PR. Try commenting \\\"@codex address that feedback\\\".\\n \\n

\",\"path\":null,\"side\":null,\"line\":null}","text_elements",[],{"_410":680,"_391":392,"_412":398},{"_413":681,"_415":-5,"_42":-5,"_416":-5,"_97":324,"_93":418},[682],{"_46":676,"_93":683},"input_text",{"_410":685,"_391":392,"_412":398},{"_413":686,"_415":-5,"_42":-5,"_416":-5,"_97":324,"_93":418},[687,688],{"_46":690,"_93":683},{"_46":689,"_93":683},"\n /workspace/tg_content_factory\n bash\n 2026-06-20\n Etc/UTC\n","# AGENTS.md instructions for /workspace/tg_content_factory\n\n\n# Repository Guidelines\n\n## Project Structure & Module Organization\nCore code lives in `src/`. Use `src/cli/` for command-line entrypoints, `src/web/` for the FastAPI dashboard, `src/services/` for orchestration/business logic, `src/telegram/` for Telethon integrations, and `src/database/` plus `src/database/repositories/` for SQLite access. Tests live under `tests/`, with route coverage in `tests/routes/` and repository coverage in `tests/repositories/`. Documentation lives in `docs/`; static web assets are in `src/web/static/` and Jinja templates in `src/web/templates/`.\n\n## Build, Test, and Development Commands\nInstall locally with `pip install -e .` from the repo root. Run `python -m src.main serve` — it spawns the embedded Telegram worker by default, so a single command gives you the web UI plus real collection, scheduler jobs, and `/agent` tools. Open `http://localhost:8080`. For Docker/k8s split deployments add `--no-worker` and run `python -m src.main worker` in a separate container. Start the Docker stack with `docker-compose up -d`.\n\nUse these validation commands during development:\n\n- `ruff check src/ tests/ conftest.py` — lint Python code.\n- `pytest tests/ -v -m \"not aiosqlite_serial\" -n auto` — run parallel-safe tests.\n- `pytest tests/ -v -m aiosqlite_serial` — run DB/thread-sensitive tests serially.\n- `pytest tests/test_web.py::test_health_endpoint -v` — run one focused test.\n\n## Coding Style & Naming Conventions\nTarget Python 3.11+ and keep code async-first. Ruff enforces imports, naming, and basic style with a `line-length` of `120`. Follow the existing naming pattern: `snake_case` for modules/functions, `PascalCase` for classes, and descriptive service names such as `content_generation_service.py`. Prefer thin CLI/web handlers that delegate to `src/services/` and `db.repos.*`.\n\n## Testing Guidelines\nPytest is the test runner, with `pytest-asyncio`, `pytest-timeout`, and `pytest-xdist` enabled. Put new tests in `tests/` using `test_.py` names. Mark raw `aiosqlite` or `cli_db` cases so they stay in the serial lane; keep pure unit tests parallel-safe when possible. Add route tests for web changes and service/repository tests for persistence logic.\n\n## Commit & Pull Request Guidelines\nRecent history uses Conventional Commit prefixes such as `feat(web): ...`, `fix: ...`, and `refactor(web): ...`. Keep commits scoped and imperative. PRs should explain the user-visible change, note schema/config impacts, link the issue or PR number when relevant, and include screenshots for dashboard/template changes. Before opening a PR, run Ruff plus both pytest lanes locally.\n\n## Security & Configuration Tips\nKeep secrets in `.env`, not in tracked files. Required runtime values include `TG_API_ID`, `TG_API_HASH`, and `WEB_PASS`; `SESSION_ENCRYPTION_KEY` should be set before storing live sessions. Prefer `config.yaml` with `${ENV_VAR}` substitution for local overrides.\n\n",{"_410":692,"_391":392,"_412":398},{"_413":693,"_415":-5,"_42":-5,"_416":-5,"_97":694,"_93":418},[695,696],"developer",{"_46":698,"_93":683},{"_46":697,"_93":683},"\n## Skills\nA skill is a set of local instructions to follow that is stored in a `SKILL.md` file. Below is the list of skills that can be used. Each entry includes a name, description, and file path so you can open the source for full instructions when using a specific skill.\n### Available skills\n- imagegen: Generate or edit raster images when the task benefits from AI-created bitmap visuals such as photos, illustrations, textures, sprites, mockups, or transparent-background cutouts. Use when Codex should create a brand-new image, transform an existing image, or derive visual variants from references, and the output should be a bitmap asset rather than repo-native code or vector. Do not use when the task is better handled by editing existing SVG/vector/code-native assets, extending an established icon or logo system, or building the visual directly in HTML/CSS/canvas. (file: /opt/codex/skills/.system/imagegen/SKILL.md)\n- openai-docs: Use when the user asks how to build with OpenAI products or APIs and needs up-to-date official documentation with citations, help choosing the latest model for a use case, or model upgrade and prompt-upgrade guidance; prioritize OpenAI docs MCP tools, use bundled references only as helper context, and restrict any fallback browsing to official OpenAI domains. (file: /opt/codex/skills/.system/openai-docs/SKILL.md)\n- plugin-creator: Create and scaffold plugin directories for Codex with a required `.codex-plugin/plugin.json`, optional plugin folders/files, and baseline placeholders you can edit before publishing or testing. Use when Codex needs to create a new local plugin, add optional plugin structure, or generate or update repo-root `.agents/plugins/marketplace.json` entries for plugin ordering and availability metadata. (file: /opt/codex/skills/.system/plugin-creator/SKILL.md)\n- skill-creator: Guide for creating effective skills. This skill should be used when users want to create a new skill (or update an existing skill) that extends Codex's capabilities with specialized knowledge, workflows, or tool integrations. (file: /opt/codex/skills/.system/skill-creator/SKILL.md)\n- skill-installer: Install Codex skills into $CODEX_HOME/skills from a curated list or a GitHub repo path. Use when a user asks to list installable skills, install a curated skill, or install a skill from another repo (including private repos). (file: /opt/codex/skills/.system/skill-installer/SKILL.md)\n### How to use skills\n- Discovery: The list above is the skills available in this session (name + description + file path). Skill bodies live on disk at the listed paths.\n- Trigger rules: If the user names a skill (with `$SkillName` or plain text) OR the task clearly matches a skill's description shown above, you must use that skill for that turn. Multiple mentions mean use them all. Do not carry skills across turns unless re-mentioned.\n- Missing/blocked: If a named skill isn't in the list or the path can't be read, say so briefly and continue with the best fallback.\n- How to use a skill (progressive disclosure):\n 1) After deciding to use a skill, open its `SKILL.md`. Read only enough to follow the workflow.\n 2) When `SKILL.md` references relative paths (e.g., `scripts/foo.py`), resolve them relative to the skill directory listed above first, and only consider other paths if needed.\n 3) If `SKILL.md` points to extra folders such as `references/`, load only the specific files needed for the request; don't bulk-load everything.\n 4) If `scripts/` exist, prefer running or patching them instead of retyping large code blocks.\n 5) If `assets/` or templates exist, reuse them instead of recreating from scratch.\n- Coordination and sequencing:\n - If multiple skills apply, choose the minimal set that covers the request and state the order you'll use them.\n - Announce which skill(s) you're using and why (one short line). If you skip an obvious skill, say why.\n- Context hygiene:\n - Keep context small: summarize long sections instead of pasting them; only load extra files when needed.\n - Avoid deep reference-chasing: prefer opening only files directly linked from `SKILL.md` unless you're blocked.\n - When variants exist (frameworks, providers, domains), pick only the relevant reference file(s) and note that choice.\n- Safety and fallback: If a skill can't be applied cleanly (missing files, unclear instructions), state the issue, pick the next-best approach, and continue.\n","\nFilesystem sandboxing defines which files can be read or written. `sandbox_mode` is `danger-full-access`: No filesystem sandboxing - all commands are permitted. Network access is enabled.\nApproval policy is currently never. Do not provide the `sandbox_permissions` for any reason, commands will be rejected.\n","turn/started",{"_391":392,"_88":701},{"_104":-5,"_42":398,"_399":702,"_401":402,"_403":703},[],"inProgress",{"_403":705,"_391":392},{"_706":707,"_93":708},"activeFlags",[],"active","thread/started",{"_711":712},"thread",{"_713":-5,"_714":-5,"_715":716,"_717":402,"_442":443,"_718":15,"_719":-5,"_720":-5,"_42":392,"_721":722,"_182":-5,"_162":723,"_724":210,"_447":725,"_403":726,"_78":727,"_728":402},"agentNickname","agentRole","cliVersion","0.128.0","createdAt","ephemeral","forkedFromId","gitInfo","modelProvider","openai","/opt/codex/sessions/2026/06/20/rollout-2026-06-20T01-55-11-019ee2bd-36b9-7be2-a5f6-f60d062c6074.jsonl","preview","vscode",{"_93":407},[],"updatedAt",[],"messages",[732],{"_42":733,"_734":735,"_736":737,"_738":737,"_413":739,"_403":740,"_415":-5,"_741":32,"_742":743,"_744":745,"_746":-5},"2808c4de-6ee6-4fe2-b5ff-b1cbac423536","author",{"_97":324,"_182":-5,"_742":755},"create_time",1781920510.564282,"update_time",{"_751":46,"_752":753},"finished_successfully","weight","metadata",{"_747":748},"recipient","all","channel","l1239dk1",{"_749":750},"inline_comments",[],"content_type","parts",[754],"## Триаж ревью (cycle 1/3)\n\nСпасибо @claude @codex. Codex — без замечаний. По находкам Claude:\n\n### Issue 1 («`logger.exception` теряет traceback из awaited-корутины») — ❌ HALLUCINATION (проверено эмпирически)\n\nРассуждение про `gi_exc_state` верное, но вывод — нет. CPython при `sys.exc_info()` вызывает `_PyErr_GetTopmostException`, который **идёт по цепочке `previous_item`** до ближайшего активного исключения. У awaited-корутины свой `exc_state` пустой, но его `previous_item` указывает на `exc_state` вызывающей корутины (`_run_single_worker`), где как раз в `except` лежит пойманное исключение. Поэтому traceback **не теряется**.\n\nМинимальный репро на том же Python 3.11.2:\n\n```python\nimport asyncio, sys, logging\nlogging.basicConfig(level=logging.DEBUG, format=\"%(levelname)s %(message)s\")\nlogger = logging.getLogger(\"t\")\n\nasync def handler():\n print(\"sys.exc_info():\", sys.exc_info()[:2])\n logger.exception(\"from awaited coroutine\")\n\nasync def main():\n try:\n raise ValueError(\"boom\")\n except Exception:\n await handler()\n\nasyncio.run(main())\n```\n\nВывод:\n```\nERROR from awaited coroutine\nTraceback (most recent call last):\n File \".../repro.py\", line 12, in main\n raise ValueError(\"boom\")\nValueError: boom\nsys.exc_info(): (, ValueError('boom'))\n```\n\n`sys.exc_info()` вернул `ValueError`, и `logger.exception` залогировал полный traceback. Это ровно паттерн нашего кода (`await self._handle_collection_exception(exc, ...)` из `except Exception`), поэтому регрессии нет — `logger.exception` логирует traceback как и раньше. `FIX` не требуется.\n\n### Note (двойной call-site `task_done()`) — SKIP → добавлю поясняющий комментарий\n\nСогласен, что контракт `task_done()` теперь в двух местах (внутри `_validate_task_pre_dispatch` на skip-путях + в `finally` основного пути) — это footgun для будущих правок, хотя поведение корректно. Добавлю краткий комментарий в финальном cleanup-проходе. Действий по логике не требуется.\n\nОстальные пункты Claude (порядок guard-ов, precedence исключений, размещение `_retried_tasks.discard`, проброс `CancelledError`) — подтверждение эквивалентности, спасибо.\nrefactor(queue): снизить сложность _run_single_worker F(54)→C (#922)\n\n## Что и зачем\n\nPR-4 из #922. `CollectionQueue._run_single_worker` (`src/collection_queue.py`) была **radon F(54)** — ~280-строчный воркер-цикл, владеющий dequeue задачи, 4 pre-dispatch guard-ами, сборкой kwargs, обработкой завершения и 6 except-ветками.\n\n## Извлечённые методы\n\n| Метод | Что | CC |\n|---|---|---|\n| `_validate_task_pre_dispatch` | 4 skip-guard (удалён/отменён/отложен/отфильтрован + shutdown) → возвращает channel или None | C(12) |\n| `_build_collect_kwargs` | progress-callback + cancel_event по сигнатуре | A(5) |\n| `_handle_collection_completion` | cancelled-requeue/cancel vs COMPLETED+note | C(16) |\n| `_handle_collection_exception` | 6 обработчиков ошибок, диспетчеризация по `isinstance` в порядке исходных except-веток → `(keep_known_task_id, stop_after_no_clients)` | B(8) |\n\n`_run_single_worker` теперь цикл «guards + pull + делегирование». **radon cc: F(54) → C(17)**; самый крупный хелпер C(16).\n\n## Поведение не меняется\n\n- Тот же порядок guard-ов, та же precedence исключений (isinstance-цепочка повторяет порядок except-клауз), те же терминальные статусы и тексты note.\n- `_retried_tasks.discard` в no-exception пути перенесён в конец тела try — эквивалент старого `else`.\n- `logger.exception` вызывается из обработчика, вызванного внутри `except Exception` — `sys.exc_info()` активен, traceback логируется как прежде.\n\n## Проверка\n\n- `ruff check src/collection_queue.py` — clean\n- `pytest -k collection_queue` — **28 passed** (все 5 типов исключений + generic + completion + guards + pause/resume + delayed requeue)\n\nRefs #922. Внешнее поведение без изменений.\n\n🤖 Generated with [Claude Code](https://claude.com/claude-code)\n@claude @codex review. Focus on critical issues: bugs, security vulnerabilities, logical errors, data loss risks, performance problems. Do NOT nitpick style, naming conventions, minor formatting, or subjective preferences — only flag issues that could break functionality or cause real harm in production.\n**Claude finished @axisrow's task in 6m 53s** —— [View job](https://github.com/axisrow/tg_content_factory/actions/runs/27856489215)\n\n---\n### Code Review\n\n- [x] Gather context\n- [x] Read `src/collection_queue.py` and diff\n- [x] Review for critical issues\n- [x] Post findings\n\n---\n\n### Summary\n\nReviewed `src/collection_queue.py` (+250/-221). The refactoring is structurally sound — guard order, exception precedence, and terminal state logic are faithfully preserved. One real regression found, one structural note.\n\n---\n\n### Issue 1 — `logger.exception` silently drops tracebacks (logging regression)\n\n**File:** `src/collection_queue.py`, lines 566 and 572 (also line 566 for the ConnectionError branch)\n\n```python\n# _handle_collection_exception — called from:\nexcept Exception as exc:\n keep_known_task_id, stop_after_no_clients = await self._handle_collection_exception(\n exc, task_id=task_id, ...\n )\n```\n\n```python\n# Inside _handle_collection_exception:\nlogger.exception(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id)\n# ...\nlogger.exception(\"Collection failed for channel %d\", channel.channel_id)\n```\n\n**What breaks:** Python coroutines have per-frame exception state (`gi_exc_state`). When CPython enters a new coroutine via `send()`, it swaps `tstate->exc_info` with the new coroutine's own (initially empty) exception state. This means `sys.exc_info()` inside `_handle_collection_exception` returns `(None, None, None)`, not the exception from `_run_single_worker`'s `except` block.\n\n`logger.exception(msg)` is shorthand for `logger.error(msg, exc_info=True)` → calls `sys.exc_info()`. With `(None, None, None)` it emits `NoneType: None` with no stack trace — the error message is logged but the traceback is silently dropped.\n\n**In the original code** the `logger.exception` calls were directly inside the `except` clauses of `_run_single_worker` (the same coroutine frame), where `sys.exc_info()` is always valid — even after an `await` — because the coroutine's own `gi_exc_state` was set when its `except` block was entered and is restored on resume.\n\n**Fix:** pass the exception explicitly:\n```python\n# Replace in _handle_collection_exception:\nlogger.exception(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id)\n# → \nlogger.error(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id, exc_info=exc)\n\nlogger.exception(\"Collection failed for channel %d\", channel.channel_id)\n# →\nlogger.error(\"Collection failed for channel %d\", channel.channel_id, exc_info=exc)\n```\n\n`exc` is already a parameter of the method, so no additional plumbing is needed.\n\n[Fix this →](https://claude.ai/code?q=In%20src%2Fcollection_queue.py%20on%20branch%20fix%2F922-run-single-worker-complexity%2C%20inside%20_handle_collection_exception%20replace%20logger.exception%28%22Collection%20failed%20for%20channel%20%25d%20%28reconnect%20failed%29%22%2C%20channel.channel_id%29%20with%20logger.error%28%22Collection%20failed%20for%20channel%20%25d%20%28reconnect%20failed%29%22%2C%20channel.channel_id%2C%20exc_info%3Dexc%29%20and%20logger.exception%28%22Collection%20failed%20for%20channel%20%25d%22%2C%20channel.channel_id%29%20with%20logger.error%28%22Collection%20failed%20for%20channel%20%25d%22%2C%20channel.channel_id%2C%20exc_info%3Dexc%29.%20The%20exc%20parameter%20is%20already%20available%20in%20the%20method%20signature.&repo=axisrow/tg_content_factory)\n\n---\n\n### Note — `task_done()` accounting (correct, worth documenting)\n\nThe split introduced an asymmetry: `_validate_task_pre_dispatch` calls `self._queue.task_done()` for each skip path internally and returns `None`, while the caller calls `task_done()` in the `finally` block for the normal path. This is correct — `continue` after a `None` return skips the `try/finally` entirely — but it's an easy footgun for future maintainers: the queue's `task_done()` contract now has two call sites. No action required; just worth a comment.\n\n---\n\n### No other critical issues\n\n- Guard order in `_validate_task_pre_dispatch` matches the original exactly\n- `_known_task_ids` cleanup behavior is preserved (including the intentional non-discard on task-deleted / cancelled skip paths)\n- Exception precedence in `_handle_collection_exception` (`isinstance` chain) mirrors the original `except` clause order\n- `_retried_tasks.discard` placement (end of `try` body vs original `else`) is semantically equivalent\n- `asyncio.CancelledError` (a `BaseException`, not `Exception`) still propagates uncaught through the new `except Exception` handler, same as before\nCodex Review: Didn't find any major issues. Keep it up!\n\n**Reviewed commit:** `13be769e38`\n\n

ℹ️ About Codex in GitHub

\n
\n\n[Your team has set up Codex to review pull requests in this repo](https://chatgpt.com/codex/cloud/settings/general). Reviews are triggered when you\n- Open a pull request for review\n- Mark a draft as ready\n- Comment \"@codex review\".\n\nIf Codex has suggestions, it will comment; otherwise it will react with 👍.\n\n\n\n\nCodex can also answer questions or update the PR. Try commenting \"@codex address that feedback\".\n \n

",{},"created",1781920581.605269,"Completing the task","event_type","info",{"_93":418,"_97":94,"_413":1379},{"_93":787,"_788":789},{"_93":764,"_765":491,"_766":767,"_768":769,"_770":-5},"pr","pr_title","pr_message","### Motivation\n- The recent refactor split `task_done()` responsibility between the skip-path helper and the main worker `finally` block, which reviewers flagged as an easy-maintainer footgun and requested an inline clarification.\n\n### Description\n- Add a short maintainer comment in `src/collection_queue.py` clarifying that `_validate_task_pre_dispatch` calls `self._queue.task_done()` for skipped dequeued items while normal collection paths call it in the surrounding `finally` block.\n\n### Testing\n- Ran `ruff check src/collection_queue.py` which passed.\n- Attempted `pytest -k collection_queue` but it could not run in this environment due to the configured xdist option (`--dist=loadfile`) not being available, so collection-specific tests were not executed here.","output_diff",{"_93":768,"_771":443,"_129":130,"_772":-5,"_323":773,"_774":775,"_776":327,"_777":778,"_779":32,"_780":781,"_782":783},"pre_apply_patch","repo_id","preapply_patch_base_commit_sha","diff --git a/src/collection_queue.py b/src/collection_queue.py\nindex 3dea1b6e87a795d0ce85d1bbeb705086a962acf2..852872d0f1463b71c8de32fc7cc7ca0297cd2b84 100644\n--- a/src/collection_queue.py\n+++ b/src/collection_queue.py\n@@ -271,50 +271,52 @@ class CollectionQueue:\n if not self._resume_gate.is_set():\n try:\n await asyncio.wait_for(self._resume_gate.wait(), timeout=1.0)\n except asyncio.TimeoutError:\n continue\n if self._shutdown_requested or self._stop_workers:\n break\n if not await self._wait_if_live_runtime_paused():\n break\n target = await self._available_target_worker_count()\n if len(self._active_task_ids) >= target:\n break\n try:\n task_id, channel, force, full = await asyncio.wait_for(\n self._queue.get(), timeout=1.0\n )\n except asyncio.TimeoutError:\n if self._queue.empty():\n break\n continue\n except asyncio.CancelledError:\n break\n \n validated = await self._validate_task_pre_dispatch(task_id, channel, force, full)\n if validated is None:\n+ # Skip paths are responsible for calling task_done(); normal\n+ # collection paths do it in the finally block below.\n continue\n channel = validated\n \n cancel_event = asyncio.Event()\n self._active_task_ids[task_id] = cancel_event\n stop_after_no_clients = False\n keep_known_task_id = False\n try:\n await self._channels.update_collection_task(task_id, CollectionTaskStatus.RUNNING)\n collect_kwargs = self._build_collect_kwargs(\n task_id, full=full, force=force, cancel_event=cancel_event\n )\n count = await self._collector.collect_single_channel(channel, **collect_kwargs)\n await self._handle_collection_completion(\n task_id, channel, count, cancel_event=cancel_event, force=force\n )\n self._retried_tasks.discard(task_id)\n except Exception as exc:\n keep_known_task_id, stop_after_no_clients = await self._handle_collection_exception(\n exc, task_id=task_id, channel=channel, force=force, full=full\n )\n finally:\n self._active_task_ids.pop(task_id, None)\n if not keep_known_task_id:\n self._known_task_ids.discard(task_id)\n","external_storage_diff",{"_784":785,"_786":-5},"files_modified","lines_added",2,"lines_removed","commit_message","docs(queue): clarify task_done ownership","additional_parent_commit_shas",[],"file_id","file_00000000789071f58d5f2995fa7c0f5d","ttl","partial_repo_snapshot","files",[790],{"_162":791,"_792":-5,"_793":794,"_795":-5},"src/collection_queue.py","contents","line_range_contents",[796],"missing_reason",{"_797":327,"_798":799,"_413":800,"_801":59},"line_range_start","line_range_end",843,[802,210,803,804,805,806,807,210,808,809,810,811,812,813,814,815,816,817,818,819,210,820,210,210,821,822,823,824,825,826,827,210,828,829,830,831,832,833,834,835,836,837,838,839,840,841,842,843,844,845,846,847,848,849,850,851,852,853,210,854,855,856,857,858,859,860,861,862,863,864,865,866,867,868,869,870,871,872,867,873,869,870,871,874,875,876,877,878,879,880,881,869,870,882,883,210,884,885,886,887,888,210,889,890,891,892,893,894,895,896,897,898,899,900,901,902,903,904,905,906,907,863,908,210,909,910,911,210,912,913,914,867,915,916,870,210,917,918,919,920,921,210,922,923,924,925,926,210,927,928,929,930,931,932,933,934,935,936,937,938,210,939,924,940,941,942,943,944,210,945,946,947,210,948,949,210,950,951,952,953,863,210,954,955,956,957,210,958,829,832,959,960,961,962,963,964,965,966,967,968,969,970,971,893,972,973,974,975,976,977,978,979,970,920,210,980,981,982,983,210,984,853,985,986,987,988,989,990,991,992,210,993,994,995,996,997,210,998,896,999,1000,1001,1002,870,1003,1004,1005,1006,1007,1008,1009,1010,1011,1012,1013,1014,1015,1016,1017,1018,1019,1020,1021,1022,896,210,1023,892,1024,896,986,987,988,989,990,1025,992,1026,896,994,1027,896,893,1028,1029,979,1030,1031,992,1017,1032,896,210,1033,1034,1035,1036,1017,1037,210,1038,1039,1040,1041,893,1042,1043,1044,979,1045,1046,1047,979,1048,1049,1050,1051,979,1052,1053,1054,1055,898,1056,1057,992,210,1058,1059,1060,1061,1062,1063,1064,1065,1066,210,1067,1068,1069,1070,1071,874,1072,1073,1074,1075,1076,1077,979,870,1078,1079,1080,1081,1082,210,1083,1084,1085,1086,210,1087,1088,1089,1090,1064,1091,1092,1093,1094,865,1095,1094,865,1096,1097,967,1098,1099,1100,1101,1102,1103,979,898,1104,210,1105,1106,1107,1108,1109,978,1110,979,1111,1112,978,1113,979,898,1104,1114,1115,1116,1117,869,1118,870,867,1119,869,1120,870,1094,865,210,866,1121,1094,865,1122,210,1123,1124,964,1125,210,1126,1127,1128,1064,1129,1130,1131,1132,863,1133,1134,1135,1136,987,1137,1138,1139,1140,897,1109,978,1141,979,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,863,1158,210,1159,1160,1161,1162,210,1163,1164,1165,1064,1166,1167,1168,1169,1170,870,1171,1172,1173,1174,870,878,1175,869,1120,1176,870,1177,1178,1179,1180,870,1168,1181,1182,870,1171,1172,1173,1174,870,878,1183,869,1120,1176,870,1177,1184,1185,1168,1186,1182,870,1171,1172,1173,1174,870,878,1187,1188,869,1120,1176,1189,870,1177,1190,1191,1192,870,1171,1193,869,1194,1195,870,1196,1197,1198,878,1199,1200,869,1120,1176,1201,870,1202,1203,1204,1205,1048,1206,1207,979,1208,1209,1210,1211,1212,863,1213,1214,210,1215,1216,210,1217,1218,964,1219,874,1220,1221,1222,1223,1224,210,1225,1226,1227,1228,1143,1153,1154,1229,1230,863,210,1231,1232,1233,1234,1235,1236,1237,1235,1238,1239,1240,1241,1242,1235,1243,1244,874,875,876,877,878,1245,1246,869,870,1235,1247,1248,1249,863,1250,210,1251,1252,1253,1254,1255,1256,1257,1258,1259,975,1260,979,1261,210,1262,1236,1263,1264,210,1265,1266,1267,969,896,1268,1017,1269,1270,1017,1271,1272,1273,975,1274,1275,1276,979,1017,1277,1278,1279,1280,1281,979,1098,1282,1100,1101,1102,1283,979,1284,1017,1285,1098,1282,1100,1101,1102,1103,979,897,987,1286,1287,1288,1289,1290,1291,1292,1293,992,1294,1295,920,1296,210,1297,1298,1299,1300,210,1301,1295,1302,1296,210,1303,1304,1143,1305,1306,1307,1308,863,210,1309,1310,1143,1311,874,1312,1313,1314,893,1315,1316,1317,1318,210,1319,1320,893,1321,1322,1323,893,1324,1030,1017,210,1325,1326,892,893,1327,895,896,1094,1328,1329,210,1330,1331,1267,901,1267,893,1332,1032,1317,902,210,1333,1334,1335,1336,1337,210,1338,1339,1340,1341,975,1342,1343,1344,1345,979,893,1346,1030,1347,1348,1289,1349,1350,1351,1352,1293,1353,1354,1355,1356,987,1357,1358,1359,1293,989,1360,1361,1362,1007,1363,1009,1364,1365,1366,1367,1368,1032,1223,1322,1369,210,1370,1371,867,1372,1373,870,1374,893,1375,1322,1376,1377,1378,903],"contains_end_of_file","from __future__ import annotations","import asyncio","import inspect","import logging","import time","from datetime import datetime, timedelta, timezone","from src.database import Database","from src.database.bundles import ChannelBundle","from src.live_runtime_pause import LiveRuntimePauseGate","from src.models import Channel, CollectionTaskStatus","from src.telegram.collector import ("," RESOLVE_USERNAME_BACKOFF_BUFFER_SEC,"," AllCollectionClientsFloodedError,"," Collector,"," NoActiveCollectionClientsError,"," UsernameResolveFloodWaitDeferredError,"," UsernameResolveRateLimitedError,",")","logger = logging.getLogger(__name__)","class CollectionQueue:"," DB_PULL_INTERVAL_SEC = 3.0"," NO_CLIENTS_RETRY_DELAY_SEC = 120"," GRACEFUL_SHUTDOWN_TIMEOUT_SEC = 120.0"," FORCE_CANCEL_TIMEOUT_SEC = 10.0"," SHUTDOWN_REQUEUE_NOTE = \"Остановка сервиса во время сбора; задача будет продолжена после запуска.\""," NO_CLIENTS_REQUEUE_NOTE = \"Отложено: нет подключённых активных аккаунтов для сбора.\""," def __init__("," self,"," collector: Collector,"," channels: ChannelBundle | Database,"," *,"," live_runtime_pause_gate: LiveRuntimePauseGate | None = None,"," ):"," self._collector = collector"," if isinstance(channels, Database):"," channels = ChannelBundle.from_database(channels)"," self._channels = channels"," self._queue: asyncio.Queue[tuple[int, Channel, bool, bool]] = asyncio.Queue(maxsize=500)"," self._supervisor: asyncio.Task | None = None"," self._workers: list[asyncio.Task] = []"," self._active_task_ids: dict[int, asyncio.Event] = {}"," self._retried_tasks: set[int] = set()"," self._delayed_requeues: set[asyncio.Task] = set()"," self._known_task_ids: set[int] = set()"," self._pull_task: asyncio.Task | None = None"," self._pull_stop = asyncio.Event()"," self._shutdown_requested = False"," self._shutdown_event = asyncio.Event()"," self._live_runtime_pause_gate = live_runtime_pause_gate"," self._resume_gate = asyncio.Event()"," self._resume_gate.set()"," self._stop_workers = False"," async def enqueue(self, channel: Channel, force: bool = False, full: bool = False) -> int | None:"," payload = {\"full\": full}"," if force:"," payload[\"force\"] = True"," task_id = await self._channels.create_collection_task_if_not_active("," channel.channel_id,"," channel.title,"," channel_username=channel.username,"," payload=payload,"," )"," if task_id is None:"," return None"," if self._shutdown_requested:"," logger.info("," \"Service is shutting down; collection task %d stays PENDING in DB\","," task_id,"," )"," return task_id"," if self._is_live_runtime_paused():"," \"Live runtime paused for agent request; collection task %d stays PENDING in DB\","," try:"," self._queue.put_nowait((task_id, channel, force, full))"," self._known_task_ids.add(task_id)"," except asyncio.QueueFull:"," logger.warning("," \"Collection queue full (maxsize=%d); task %d stays PENDING in DB \""," \"and will be picked up on the next restart/requeue cycle\","," self._queue.maxsize,"," self._ensure_worker()"," return task_id"," async def cancel_task(self, task_id: int, note: str | None = None) -> bool:"," cancel_event = self._active_task_ids.get(task_id)"," if cancel_event is not None:"," cancel_event.set()"," return await self._channels.cancel_collection_task(task_id, note=note)"," async def clear_pending_tasks(self) -> int:"," deleted = await self._channels.delete_pending_channel_tasks()"," removed_from_memory = 0"," while True:"," try:"," self._queue.get_nowait()"," except asyncio.QueueEmpty:"," break"," else:"," self._queue.task_done()"," removed_from_memory += 1"," for task in list(self._delayed_requeues):"," task.cancel()"," self._delayed_requeues.clear()"," self._known_task_ids.clear()"," logger.info("," \"Cleared %d pending collection tasks from DB and %d queued items from memory\","," deleted,"," removed_from_memory,"," return deleted"," @property"," def is_paused(self) -> bool:"," return not self._resume_gate.is_set()"," def pause(self) -> None:"," if self._resume_gate.is_set():"," self._resume_gate.clear()"," \"Collection queue paused (active tasks %s allowed to finish)\","," list(self._active_task_ids.keys()),"," def resume(self) -> None:"," if not self._resume_gate.is_set():"," self._resume_gate.set()"," self._ensure_worker()"," logger.info(\"Collection queue resumed\")"," def _target_worker_count(self) -> int:"," getter = getattr(self._collector, \"collection_worker_count\", None)"," if callable(getter):"," return max(1, int(getter()))"," return 1"," async def _available_target_worker_count(self) -> int:"," slot_getter = getattr(self._collector, \"available_collection_slot_count\", None)"," if callable(slot_getter):"," slots = slot_getter()"," if asyncio.iscoroutine(slots):"," slots = await slots"," active_count = len(self._active_task_ids)"," configured = self._target_worker_count()"," desired = active_count + max(0, int(slots))"," if desired <= 0:"," return 1"," return max(1, active_count, min(configured, desired))"," getter = getattr(self._collector, \"available_collection_worker_count\", None)"," count = getter()"," if asyncio.iscoroutine(count):"," count = await count"," return max(1, int(count))"," return self._target_worker_count()"," def _ensure_supervisor(self) -> None:"," if self._supervisor is None or self._supervisor.done():"," self._supervisor = asyncio.create_task(self._run_supervisor())"," def _ensure_worker(self) -> None:"," self._ensure_supervisor()"," def _is_live_runtime_paused(self) -> bool:"," return ("," self._live_runtime_pause_gate is not None"," and self._live_runtime_pause_gate.is_paused"," async def _wait_if_live_runtime_paused(self) -> bool:"," if self._live_runtime_pause_gate is None:"," return True"," return await self._live_runtime_pause_gate.wait_if_paused(stop_event=self._shutdown_event)"," def _schedule_requeue_after_delay("," task_id: int,"," channel: Channel,"," force: bool,"," full: bool,"," run_after,"," ) -> None:"," async def _requeue_later() -> None:"," remaining = max(0.0, run_after.timestamp() - time.time())"," if remaining > 0:"," await asyncio.sleep(remaining)"," if self._shutdown_requested:"," self._known_task_ids.discard(task_id)"," return"," self._queue.put_nowait((task_id, channel, force, full))"," self._known_task_ids.add(task_id)"," except asyncio.QueueFull:"," logger.warning("," \"Collection queue full on delayed requeue; task %d stays PENDING \""," \"in DB and will be picked up by the DB pull loop\","," task_id,"," )"," self._known_task_ids.add(task_id)"," task = asyncio.create_task(_requeue_later())"," self._delayed_requeues.add(task)"," task.add_done_callback(self._delayed_requeues.discard)"," async def _run_supervisor(self) -> None:"," while not self._shutdown_requested and not self._stop_workers:"," if not self._resume_gate.is_set():"," try:"," await asyncio.wait_for(self._resume_gate.wait(), timeout=1.0)"," except asyncio.TimeoutError:"," continue"," if self._shutdown_requested:"," break"," self._workers = [w for w in self._workers if not w.done()]"," target = await self._available_target_worker_count()"," while len(self._workers) < target:"," w = asyncio.create_task(self._run_single_worker())"," self._workers.append(w)"," if not self._workers:"," done, _ = await asyncio.wait("," self._workers,"," timeout=1.0,"," return_when=asyncio.FIRST_COMPLETED,"," if done:"," for w in done:"," if w in self._workers:"," self._workers.remove(w)"," try:"," exc = w.exception()"," except asyncio.CancelledError:"," continue"," if exc is not None:"," logger.exception("," \"Collection queue worker crashed\","," exc_info=(type(exc), exc, exc.__traceback__),"," )"," if not self._queue.empty() and len(self._workers) < target:"," continue"," if ("," self._queue.empty()"," and not self._active_task_ids"," and not any(not worker.done() for worker in self._workers)"," ):"," async def _run_single_worker(self) -> None:"," if self._shutdown_requested or self._stop_workers:"," if self._shutdown_requested or self._stop_workers:"," if not await self._wait_if_live_runtime_paused():"," if len(self._active_task_ids) >= target:"," task_id, channel, force, full = await asyncio.wait_for("," self._queue.get(), timeout=1.0"," except asyncio.TimeoutError:"," if self._queue.empty():"," except asyncio.CancelledError:"," validated = await self._validate_task_pre_dispatch(task_id, channel, force, full)"," if validated is None:"," # Skip paths are responsible for calling task_done(); normal"," # collection paths do it in the finally block below."," channel = validated"," cancel_event = asyncio.Event()"," self._active_task_ids[task_id] = cancel_event"," stop_after_no_clients = False"," keep_known_task_id = False"," await self._channels.update_collection_task(task_id, CollectionTaskStatus.RUNNING)"," collect_kwargs = self._build_collect_kwargs("," task_id, full=full, force=force, cancel_event=cancel_event"," count = await self._collector.collect_single_channel(channel, **collect_kwargs)"," await self._handle_collection_completion("," task_id, channel, count, cancel_event=cancel_event, force=force"," self._retried_tasks.discard(task_id)"," except Exception as exc:"," keep_known_task_id, stop_after_no_clients = await self._handle_collection_exception("," exc, task_id=task_id, channel=channel, force=force, full=full"," finally:"," self._active_task_ids.pop(task_id, None)"," if not keep_known_task_id:"," self._known_task_ids.discard(task_id)"," if stop_after_no_clients:"," self._stop_workers = True"," def _build_collect_kwargs("," self, task_id: int, *, full: bool, force: bool, cancel_event: asyncio.Event"," ) -> dict:"," \"\"\"Build the kwargs for ``collect_single_channel``, including a progress"," callback bound to ``task_id`` and a ``cancel_event`` only when the"," collector's signature accepts one. Split out of ``_run_single_worker`` (#922)."," \"\"\""," async def _progress(count: int) -> None:"," await self._channels.update_collection_task_progress(task_id, count)"," collect_kwargs = {"," \"full\": full,"," \"progress_callback\": _progress,"," \"force\": force,"," }"," signature = inspect.signature(self._collector.collect_single_channel)"," accepts_cancel_event = ("," \"cancel_event\" in signature.parameters"," or any("," parameter.kind == inspect.Parameter.VAR_KEYWORD"," for parameter in signature.parameters.values()"," except (TypeError, ValueError):"," accepts_cancel_event = True"," if accepts_cancel_event:"," collect_kwargs[\"cancel_event\"] = cancel_event"," return collect_kwargs"," async def _validate_task_pre_dispatch("," self, task_id: int, channel: Channel, force: bool, full: bool"," ) -> Channel | None:"," \"\"\"Run every pre-dispatch guard for a dequeued task."," Returns the channel to collect (refreshed from DB when applicable), or"," ``None`` when the task must be skipped — in which case this method has"," already marked the queue item done and cancelled/requeued as needed."," Split out of ``_run_single_worker`` (#922)."," task = await self._channels.get_collection_task(task_id)"," if task is None:"," logger.info(\"Task %d skipped: task was deleted before collection\", task_id)"," self._queue.task_done()"," if task and task.status == CollectionTaskStatus.CANCELLED:"," if task.run_after is not None:"," remaining = task.run_after.timestamp() - time.time()"," self._schedule_requeue_after_delay("," task_id=task_id,"," channel=channel,"," force=force,"," full=full,"," run_after=task.run_after,"," return None"," fresh_channel = None"," if channel.id is not None:"," fresh_channel = await self._channels.get_by_pk(channel.id)"," if fresh_channel is None:"," await self._channels.cancel_collection_task("," note=\"Канал удалён до начала сбора.\","," logger.info("," \"Task %d skipped: channel %d was deleted before collection\","," channel.channel_id,"," if fresh_channel is not None:"," channel = fresh_channel"," if channel.is_filtered and not force:"," await self._channels.cancel_collection_task("," note=\"Канал отфильтрован до начала сбора.\","," \"Task %d skipped: channel %d is filtered\","," channel.channel_id,"," self._known_task_ids.discard(task_id)"," return channel"," async def _handle_collection_completion("," self, task_id: int, channel: Channel, count: int, *, cancel_event: asyncio.Event, force: bool"," \"\"\"Persist the terminal status of a finished collection."," Requeues (on shutdown) or cancels when the run was cancelled, else marks"," it COMPLETED with an optional \"skipped\" note when the channel became"," filtered mid-run. Split out of ``_run_single_worker`` (#922)."," persisted = await self._channels.get_collection_task(task_id)"," persisted_cancelled = ("," persisted is not None"," and persisted.status == CollectionTaskStatus.CANCELLED"," collector_cancelled = bool(getattr(self._collector, \"is_cancelled\", False))"," cancelled = cancel_event.is_set() or persisted_cancelled or collector_cancelled"," if cancelled:"," if self._shutdown_requested and not persisted_cancelled:"," await self._reset_task_to_pending_after_shutdown(task_id)"," logger.info(\"Task %d requeued after service shutdown interrupted collection\", task_id)"," except (ValueError, RuntimeError):"," logger.debug(\"Could not reset task %d during shutdown\", task_id)"," note=\"Задача отменена во время сбора.\","," logger.info(\"Task %d cancelled during collection\", task_id)"," return"," note = None"," if count == 0 and not force and channel.id is not None:"," after_ch = await self._channels.get_by_pk(channel.id)"," if after_ch and after_ch.is_filtered and not channel.is_filtered:"," before_flags = set((channel.filter_flags or \"\").split(\",\")) - {\"\"}"," after_flags = set((after_ch.filter_flags or \"\").split(\",\")) - {\"\"}"," new_flags = after_flags - before_flags"," reason = next(iter(new_flags), \"low_subscriber_ratio\")"," note = f\"Пропущен: {reason}\""," await self._channels.update_collection_task("," task_id,"," CollectionTaskStatus.COMPLETED,"," messages_collected=count,"," note=note,"," logger.info(\"Collected %d messages from channel %d\", count, channel.channel_id)"," async def _handle_collection_exception("," self, exc: Exception, *, task_id: int, channel: Channel, force: bool, full: bool"," ) -> tuple[bool, bool]:"," \"\"\"Handle a failure raised while collecting a single channel."," Returns ``(keep_known_task_id, stop_after_no_clients)`` for the worker"," loop's finally block. The ``isinstance`` chain mirrors the original"," except-clause precedence exactly. Split out of ``_run_single_worker`` (#922)."," if isinstance(exc, AllCollectionClientsFloodedError):"," run_after = exc.next_available_at + timedelta(seconds=5)"," note = ("," \"Отложено: все аккаунты во Flood Wait \""," f\"до {exc.next_available_at.astimezone(timezone.utc).isoformat()}\""," self._retried_tasks.discard(task_id)"," await self._channels.reschedule_collection_task(task_id, run_after=run_after, note=note)"," self._schedule_requeue_after_delay("," task_id=task_id, channel=channel, force=force, full=full, run_after=run_after"," \"Rescheduled collection task %d for channel %d until %s: all clients flooded\","," run_after.isoformat(),"," return True, False"," if isinstance(exc, UsernameResolveFloodWaitDeferredError):"," run_after = exc.next_available_at + timedelta("," seconds=RESOLVE_USERNAME_BACKOFF_BUFFER_SEC"," \"Отложено: Flood Wait на resolve_username до \""," f\"{run_after.astimezone(timezone.utc).isoformat()}\""," \"Rescheduled collection task %d for channel %d until %s: username resolve flood wait\","," if isinstance(exc, UsernameResolveRateLimitedError):"," run_after = exc.run_after_with_buffer()"," \"Отложено: resolve_username rate-limited до \""," \"Rescheduled collection task %d for channel %d until %s: \""," \"username resolve rate-limited on %s\","," exc.phone,"," if isinstance(exc, NoActiveCollectionClientsError):"," run_after = datetime.now(timezone.utc) + timedelta("," seconds=self.NO_CLIENTS_RETRY_DELAY_SEC"," await self._channels.reschedule_collection_task("," run_after=run_after,"," note=self.NO_CLIENTS_REQUEUE_NOTE,"," drained_task_ids = self._drain_memory_queue()"," for drained_task_id in drained_task_ids:"," self._known_task_ids.discard(drained_task_id)"," \"Deferred collection task %d for channel %d until %s: no active connected clients; \""," \"left %d queued task(s) pending in DB\","," len(drained_task_ids),"," return False, True"," if isinstance(exc, ConnectionError):"," requeued = await self._try_reconnect_and_requeue(task_id, channel, full, force, exc)"," if not requeued:"," await self._update_task_status_shutdown_safe("," task_id, CollectionTaskStatus.FAILED, error=str(exc)[:500],"," logger.exception(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id)"," return requeued, False"," self._retried_tasks.discard(task_id)"," await self._update_task_status_shutdown_safe("," task_id, CollectionTaskStatus.FAILED, error=str(exc)[:500],"," logger.exception(\"Collection failed for channel %d\", channel.channel_id)"," return False, False"," async def _run_worker(self) -> None:"," await self._run_single_worker()"," async def _update_task_status_shutdown_safe("," self, task_id: int, status: CollectionTaskStatus, **kwargs"," \"\"\"Update collection task status, suppressing DB errors during shutdown.\"\"\""," await self._channels.update_collection_task(task_id, status, **kwargs)"," except (ValueError, RuntimeError):"," if not self._shutdown_requested:"," raise"," logger.debug(\"Could not update task %d status during shutdown\", task_id)"," async def _reset_task_to_pending_after_shutdown(self, task_id: int) -> None:"," reset = getattr(self._channels, \"reset_collection_task_to_pending\", None)"," if callable(reset):"," await reset(task_id, note=self.SHUTDOWN_REQUEUE_NOTE)"," CollectionTaskStatus.PENDING,"," note=self.SHUTDOWN_REQUEUE_NOTE,"," async def _try_reconnect_and_requeue("," self, task_id: int, channel: Channel, full: bool, force: bool, exc: Exception"," ) -> bool:"," if task_id in self._retried_tasks:"," return False"," pool = getattr(self._collector, \"_pool\", None)"," if pool is None or not hasattr(pool, \"reconnect_phone\"):"," reconnected = False"," for phone in list(pool.clients):"," result = await pool.reconnect_phone(phone)"," reconnected = reconnected or result"," if not reconnected:"," self._retried_tasks.add(task_id)"," await self._channels.update_collection_task(task_id, CollectionTaskStatus.PENDING, note=\"Reconnect retry\")"," \"Collection queue full on reconnect requeue; task %d stays PENDING \""," \"and will be picked up by the DB pull loop\","," logger.warning("," \"ConnectionError for channel %d, reconnected and re-queued task %d: %s\","," channel.channel_id, task_id, exc,"," return True"," async def _ingest_pending_tasks(self) -> int:"," if not self._resume_gate.is_set() or self._is_live_runtime_paused():"," return 0"," availability_getter = getattr(self._collector, \"get_collection_availability\", None)"," if callable(availability_getter):"," availability = availability_getter()"," if asyncio.iscoroutine(availability):"," availability = await availability"," if getattr(availability, \"state\", None) == \"no_connected_active\":"," \"[collection-queue] Pending-task ingest throttled: no active connected clients\""," return 0"," resolve_backoff_remaining = 0"," if pool is not None:"," resolve_backoff_remaining = pool.get_resolve_username_backoff_remaining_sec()"," pending = await self._channels.get_pending_channel_tasks()"," count = 0"," for task in pending:"," if task.id is None or task.id in self._known_task_ids:"," if task.channel_id is None:"," logger.warning(\"Skipping task %d: channel_id is None\", task.id)"," channel = await self._channels.get_by_channel_id(task.channel_id)"," if channel is None:"," await self._channels.cancel_collection_task(task.id)"," \"Cancelled orphaned task %d: channel %d not found\","," task.id,"," task.channel_id,"," force = bool((task.payload or {}).get(\"force\", False))"," full = bool((task.payload or {}).get(\"full\", False))"," if resolve_backoff_remaining > 0 and channel.username:"," run_after = datetime.now(timezone.utc) + timedelta("," seconds=resolve_backoff_remaining + RESOLVE_USERNAME_BACKOFF_BUFFER_SEC"," task_id=task.id,"," run_after=run_after,"," count += 1"," if task.run_after is not None and task.run_after.timestamp() > time.time():"," self._queue.put_nowait((task.id, channel, force, full))"," self._known_task_ids.add(task.id)"," except asyncio.QueueFull:"," logger.warning("," \"Collection queue full during pending-task ingest; task %d stays PENDING \""," \"in DB and will be picked up after the queue drains\","," task.id,"," )"," count += 1"," if count:"," return count"," async def requeue_startup_tasks(self) -> int:"," reset_count = await self._channels.reset_orphaned_running_tasks()"," if reset_count:"," logger.info(\"Reset %d orphaned RUNNING tasks to PENDING\", reset_count)"," count = await self._ingest_pending_tasks()"," logger.info(\"Re-enqueued %d pending collection tasks on startup\", count)"," def start_db_pull(self, *, interval: float | None = None) -> None:"," if self._pull_task is not None and not self._pull_task.done():"," self._pull_stop.clear()"," self._pull_task = asyncio.create_task("," self._db_pull_loop(interval or self.DB_PULL_INTERVAL_SEC),"," name=\"collection-queue-db-pull\","," async def stop_db_pull(self, timeout: float = 5.0) -> None:"," if self._pull_task is None:"," self._pull_stop.set()"," await asyncio.wait_for(self._pull_task, timeout=timeout)"," except asyncio.TimeoutError:"," self._pull_task.cancel()"," await self._pull_task"," except (asyncio.CancelledError, Exception):"," pass"," self._pull_task = None"," async def _db_pull_loop(self, interval: float) -> None:"," while not self._pull_stop.is_set():"," await self._ingest_pending_tasks()"," except Exception:"," logger.exception(\"[collection-queue] DB pull failed\")"," await asyncio.wait_for(self._pull_stop.wait(), timeout=interval)"," def _drain_memory_queue(self) -> set[int]:"," drained: set[int] = set()"," queued_task_id, *_ = self._queue.get_nowait()"," drained.add(queued_task_id)"," return drained"," async def _cancel_delayed_requeues(self) -> None:"," pending = list(self._delayed_requeues)"," await task"," async def shutdown(self, *, grace_timeout: float | None = None) -> None:"," self._shutdown_requested = True"," self._shutdown_event.set()"," await self.stop_db_pull()"," await self._cancel_delayed_requeues()"," if self._supervisor and not self._supervisor.done():"," timeout = self.GRACEFUL_SHUTDOWN_TIMEOUT_SEC if grace_timeout is None else grace_timeout"," active_ids = list(self._active_task_ids.keys())"," if active_ids:"," \"Останавливаем сервис: ждём завершения %d активной(ых) задачи(ч) сбора \""," \"(до %.0f сек). Новые задачи останутся pending в БД.\","," len(active_ids),"," timeout,"," await asyncio.wait_for(asyncio.shield(self._supervisor), timeout=timeout)"," remaining_ids = list(self._active_task_ids.keys())"," if remaining_ids:"," \"%d активная(ых) задачи(ч) сбора не завершилась за %.0f сек; \""," \"останавливаем сбор и возвращаем в pending.\","," len(remaining_ids),"," timeout,"," await self._collector.cancel()"," for cancel_evt in self._active_task_ids.values():"," cancel_evt.set()"," self._stop_workers = True"," await asyncio.wait_for("," asyncio.shield(self._supervisor),"," timeout=self.FORCE_CANCEL_TIMEOUT_SEC,"," for tid in list(self._active_task_ids.keys()):"," await self._reset_task_to_pending_after_shutdown(tid)"," self._supervisor.cancel()"," await self._supervisor"," pass"," for w in self._workers:"," if not w.done():"," w.cancel()"," await asyncio.gather(*self._workers, return_exceptions=True)"," logger.exception(\"Collection queue supervisor failed during shutdown\")"," drained = self._drain_memory_queue()"," if drained:"," \"Left %d queued collection task(s) pending in DB for the next worker start\","," len(drained),"," for tid in list(self._active_task_ids.keys()):"," await self._reset_task_to_pending_after_shutdown(tid)"," logger.exception(\"Failed to reset active collection task during shutdown\")"," self._active_task_ids.clear()"," self._retried_tasks.clear()",[1380,1381,1382],{"_751":46,"_46":1387},{"_751":1384,"_162":791,"_797":1385,"_798":1386},{"_751":46,"_46":1383},"\n* Committed the change with `docs(queue): clarify task_done ownership` (`f0a96d8`) and created a PR via `make_pr`.\n\n**Testing**\n* ✅ `ruff check src/collection_queue.py`\n* ⚠️ `pytest -k collection_queue` (pytest rejected configured `--dist=loadfile`, likely because `pytest-xdist` is unavailable in this environment)","repo_file_citation",294,298,"**Summary**\n* Added a maintainer comment documenting the `task_done()` ownership split: skip paths handled by `_validate_task_pre_dispatch`, normal collection paths handled by the surrounding `finally` block. ",{"_93":324,"_42":85,"_97":324,"_1390":1391,"_1392":1393,"_1394":1395,"_133":-5,"_120":1396},[84],"input_items",[1413,1414,1415,1416,1417],"external_post_config",{"_1397":1398,"_263":197,"_1399":304,"_274":-5,"_771":257,"_1400":-5,"_1401":1402,"_1403":1404,"_1405":-5,"_1406":-5,"_1407":1408,"_1409":15,"_1410":59,"_1411":54,"_1412":15},"user_model_slug","slug",1781920500.108606,"installation_id",66365128,"pr_number","review_trigger","comment_id",4755973830,"comment_type","issue","pr_write_guard_token","pending_pr_reaction_id","pending_comment_reaction_id",372477434,"comment_if_no_findings","comment_on_error","share_url","is_parallel_review",{"_93":418,"_97":324,"_413":1427},{"_311":312,"_313":314,"_1424":318,"_1425":130,"_320":-5,"_93":1426},{"_93":1418,"_313":1423,"_162":-5,"_1420":-5,"_1421":-5},{"_93":1418,"_313":1422,"_162":-5,"_1420":-5,"_1421":-5},{"_93":1418,"_313":1419,"_162":-5,"_1420":-5,"_1421":-5},"pull_request_comment","Codex Review: Didn't find any major issues. Keep it up!\n\n**Reviewed commit:** `13be769e38`\n\n

ℹ️ About Codex in GitHub

","side","line","**Claude finished @axisrow's task in 6m 53s** —— [View job](https://github.com/axisrow/tg_content_factory/actions/runs/27856489215)\n\n---\n### Code Review\n\n- [x] Gather context\n- [x] Read `src/collection_queue.py` and diff\n- [x] Review for critical issues\n- [x] Post findings\n\n---\n\n### Summary\n\nReviewed `src/collection_queue.py` (+250/-221). The refactoring is structurally sound — guard order, exception precedence, and terminal state logic are faithfully preserved. One real regression found, one structural note.\n\n---\n\n### Issue 1 — `logger.exception` silently drops tracebacks (logging regression)\n\n**File:** `src/collection_queue.py`, lines 566 and 572 (also line 566 for the ConnectionError branch)\n\n```python\n# _handle_collection_exception — called from:\nexcept Exception as exc:\n keep_known_task_id, stop_after_no_clients = await self._handle_collection_exception(\n exc, task_id=task_id, ...\n )\n```\n\n```python\n# Inside _handle_collection_exception:\nlogger.exception(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id)\n# ...\nlogger.exception(\"Collection failed for channel %d\", channel.channel_id)\n```\n\n**What breaks:** Python coroutines have per-frame exception state (`gi_exc_state`). When CPython enters a new coroutine via `send()`, it swaps `tstate->exc_info` with the new coroutine's own (initially empty) exception state. This means `sys.exc_info()` inside `_handle_collection_exception` returns `(None, None, None)`, not the exception from `_run_single_worker`'s `except` block.\n\n`logger.exception(msg)` is shorthand for `logger.error(msg, exc_info=True)` → calls `sys.exc_info()`. With `(None, None, None)` it emits `NoneType: None` with no stack trace — the error message is logged but the traceback is silently dropped.\n\n**In the original code** the `logger.exception` calls were directly inside the `except` clauses of `_run_single_worker` (the same coroutine frame), where `sys.exc_info()` is always valid — even after an `await` — because the coroutine's own `gi_exc_state` was set when its `except` block was entered and is restored on resume.\n\n**Fix:** pass the exception explicitly:\n```python\n# Replace in _handle_collection_exception:\nlogger.exception(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id)\n# → \nlogger.error(\"Collection failed for channel %d (reconnect failed)\", channel.channel_id, exc_info=exc)\n\nlogger.exception(\"Collection failed for channel %d\", channel.channel_id)\n# →\nlogger.error(\"Collection failed for channel %d\", channel.channel_id, exc_info=exc)\n```\n\n`exc` is already a parameter of the method, so no additional plumbing is needed.\n\n[Fix this →](https://claude.ai/code?q=In%20src%2Fcollection_queue.py%20on%20branch%20fix%2F922-run-single-worker-complexity%2C%20inside%20_handle_collection_exception%20replace%20logger.exception%28%22Collection%20failed%20for%20channel%20%25d%20%28reconnect%20failed%29%22%2C%20channel.channel_id%29%20with%20logger.error%28%22Collection%20failed%20for%20channel%20%25d%20%28reconnect%20failed%29%22%2C%20channel.channel_id%2C%20exc_info%3Dexc%29%20and%20logger.exception%28%22Collection%20failed%20for%20channel%20%25d%22%2C%20channel.channel_id%29%20with%20logger.error%28%22Collection%20failed%20for%20channel%20%25d%22%2C%20channel.channel_id%2C%20exc_info%3Dexc%29.%20The%20exc%20parameter%20is%20already%20available%20in%20the%20method%20signature.&repo=axisrow/tg_content_factory)\n\n---\n\n### Note — `task_done()` accounting (correct, worth documenting)\n\nThe split introduced an asymmetry: `_validate_task_pre_dispatch` calls `self._queue.task_done()` for each skip path internally and returns `None`, while the caller calls `task_done()` in the `finally` block for the normal path. This is correct — `continue` after a `None` return skips the `try/finally` entirely — but it's an easy footgun for future maintainers: the queue's `task_done()` contract now has two call sites. No action required; just worth a comment.\n\n---\n\n### No other critical issues\n\n- Guard order in `_validate_task_pre_dispatch` matches the original exactly\n- `_known_task_ids` cleanup behavior is preserved (including the intentional non-discard on task-deleted / cancelled skip paths)\n- Exception precedence in `_handle_collection_exception` (`isinstance` chain) mirrors the original `except` clause order\n- `_retried_tasks.discard` placement (end of `try` body vs original `else`) is semantically equivalent\n- `asyncio.CancelledError` (a `BaseException`, not `Exception`) still propagates uncaught through the new `except Exception` handler, same as before","@claude @codex review. Focus on critical issues: bugs, security vulnerabilities, logical errors, data loss risks, performance problems. Do NOT nitpick style, naming conventions, minor formatting, or subjective preferences — only flag issues that could break functionality or cause real harm in production.","base_ref","head_ref","pull_request_info",[1428],{"_751":46,"_46":1429},"## Триаж ревью (cycle 1/3)\n\nСпасибо @claude @codex. Codex — без замечаний. По находкам Claude:\n\n### Issue 1 («`logger.exception` теряет traceback из awaited-корутины») — ❌ HALLUCINATION (проверено эмпирически)\n\nРассуждение про `gi_exc_state` верное, но вывод — нет. CPython при `sys.exc_info()` вызывает `_PyErr_GetTopmostException`, который **идёт по цепочке `previous_item`** до ближайшего активного исключения. У awaited-корутины свой `exc_state` пустой, но его `previous_item` указывает на `exc_state` вызывающей корутины (`_run_single_worker`), где как раз в `except` лежит пойманное исключение. Поэтому traceback **не теряется**.\n\nМинимальный репро на том же Python 3.11.2:\n\n```python\nimport asyncio, sys, logging\nlogging.basicConfig(level=logging.DEBUG, format=\"%(levelname)s %(message)s\")\nlogger = logging.getLogger(\"t\")\n\nasync def handler():\n print(\"sys.exc_info():\", sys.exc_info()[:2])\n logger.exception(\"from awaited coroutine\")\n\nasync def main():\n try:\n raise ValueError(\"boom\")\n except Exception:\n await handler()\n\nasyncio.run(main())\n```\n\nВывод:\n```\nERROR from awaited coroutine\nTraceback (most recent call last):\n File \".../repro.py\", line 12, in main\n raise ValueError(\"boom\")\nValueError: boom\nsys.exc_info(): (, ValueError('boom'))\n```\n\n`sys.exc_info()` вернул `ValueError`, и `logger.exception` залогировал полный traceback. Это ровно паттерн нашего кода (`await self._handle_collection_exception(exc, ...)` из `except Exception`), поэтому регрессии нет — `logger.exception` логирует traceback как и раньше. `FIX` не требуется.\n\n### Note (двойной call-site `task_done()`) — SKIP → добавлю поясняющий комментарий\n\nСогласен, что контракт `task_done()` теперь в двух местах (внутри `_validate_task_pre_dispatch` на skip-путях + в `finally` основного пути) — это footgun для будущих правок, хотя поведение корректно. Добавлю краткий комментарий в финальном cleanup-проходе. Действий по логике не требуется.\n\nОстальные пункты Claude (порядок guard-ов, precedence исключений, размещение `_retried_tasks.discard`, проброс `CancelledError`) — подтверждение эквивалентности, спасибо.",[1686,1687,1688],[],{"_756":757,"_46":758,"_759":760},{"_730":1677},{"_334":1676},{"_334":1465},{"_303":304,"_295":305,"_306":307,"_308":15,"_309":59,"_310":15,"_311":312,"_313":314,"_315":267,"_316":128,"_317":318,"_319":130,"_320":321,"_322":-5,"_323":-5,"_324":1464,"_326":327,"_328":327,"_329":330,"_331":332},{"_42":124,"_194":195,"_196":197,"_198":15,"_199":200,"_201":202,"_203":1453,"_205":-5,"_206":-5,"_207":1454,"_209":210,"_211":210,"_212":1455,"_214":1456,"_216":1457,"_218":-5,"_219":220,"_221":222,"_223":224,"_225":1458,"_55":-5,"_120":227,"_228":1459,"_230":1460,"_232":233,"_234":15,"_235":15},{"_134":1446},[1440,1441,1442,1443,1444,1445],{"_149":172,"_151":166,"_153":167,"_155":164,"_157":173,"_159":160,"_161":32,"_162":-5},{"_149":171,"_151":166,"_153":167,"_155":164,"_157":168,"_159":160,"_161":32,"_162":-5},{"_149":169,"_151":166,"_153":167,"_155":164,"_157":170,"_159":160,"_161":32,"_162":-5},{"_149":165,"_151":166,"_153":167,"_155":164,"_157":168,"_159":160,"_161":32,"_162":-5},{"_149":163,"_151":152,"_153":154,"_155":164,"_157":158,"_159":160,"_161":32,"_162":-5},{"_149":150,"_151":152,"_153":154,"_155":156,"_157":158,"_159":160,"_161":32,"_162":-5},[1447,1448,1449],{"_178":1452,"_180":191},{"_178":1451,"_180":187},{"_178":1450,"_180":181},{"_182":183,"_93":184,"_120":185},{"_182":188,"_93":184,"_120":189},{"_182":192,"_93":184,"_120":193},{"_297":298,"_299":-5,"_300":-5,"_301":-5,"_302":-5},[257],{"_257":1461},{"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256},{},[],{"_238":59},{"_236":59,"_237":210},{"_42":259,"_182":260,"_261":1462,"_263":197,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":64,"_275":15,"_276":-5,"_277":-5,"_278":-5,"_279":-5,"_280":-5,"_281":-5,"_161":282,"_283":-5,"_55":1463},{"_289":290,"_42":291,"_93":292,"_293":294,"_295":296},{"_285":15,"_286":15,"_287":15,"_288":15},{"_289":290,"_182":290,"_333":-5,"_293":294,"_42":291},[1466,1467,1468,1469,1470,1471,1472,1473,1474,1475,1476,1477,1478,1479,1480,1481,1482,1483,1484,1485,1486,1487,1488,1489,1490,1491,1492,1493,1494,1495,1496,1497,1498,1499,1500,1501,1502,1503,1504,1505,1506,1507,1508,1509,1510,1511,1512,1513,1514,1515,1516,1517],{"_155":709,"_389":1672},{"_155":404,"_389":1669},{"_155":699,"_389":1666},{"_155":408,"_389":1661},{"_155":408,"_389":1656},{"_155":408,"_389":1652},{"_155":422,"_389":1647},{"_155":422,"_389":1643},{"_155":408,"_389":1640},{"_155":408,"_389":1638},{"_155":422,"_389":1634},{"_155":408,"_389":1632},{"_155":408,"_389":1630},{"_155":422,"_389":1626},{"_155":408,"_389":1624},{"_155":408,"_389":1622},{"_155":422,"_389":1618},{"_155":408,"_389":1616},{"_155":422,"_389":1612},{"_155":408,"_389":1608},{"_155":408,"_389":1606},{"_155":422,"_389":1601},{"_155":408,"_389":1599},{"_155":408,"_389":1597},{"_155":408,"_389":1595},{"_155":408,"_389":1593},{"_155":408,"_389":1591},{"_155":408,"_389":1589},{"_155":408,"_389":1587},{"_155":408,"_389":1585},{"_155":408,"_389":1583},{"_155":422,"_389":1579},{"_155":422,"_389":1575},{"_155":408,"_389":1571},{"_155":408,"_389":1569},{"_155":408,"_389":1567},{"_155":422,"_389":1563},{"_155":408,"_389":1561},{"_155":408,"_389":1559},{"_155":422,"_389":1555},{"_155":408,"_389":1553},{"_155":422,"_389":1546},{"_155":408,"_389":1544},{"_155":422,"_389":1540},{"_155":408,"_389":1537},{"_155":408,"_389":1535},{"_155":422,"_389":1531},{"_155":408,"_389":1529},{"_155":422,"_389":1527},{"_155":408,"_389":1523},{"_155":404,"_389":1521},{"_155":388,"_389":1518},{"_391":392,"_88":1519},{"_394":395,"_396":397,"_104":-5,"_42":398,"_399":1520,"_401":402,"_403":114},[],{"_403":1522,"_391":392},{"_93":407},{"_410":1524,"_391":392,"_412":398},{"_413":1525,"_415":-5,"_42":-5,"_416":417,"_97":94,"_93":418},[1526],{"_46":420,"_93":421},{"_410":1528,"_391":392,"_412":398},{"_42":425,"_416":417,"_46":420,"_93":426},{"_410":1530,"_391":392,"_412":398},{"_429":430,"_431":432,"_93":433},{"_410":1532,"_391":392,"_412":398},{"_436":437,"_438":439,"_440":1533,"_442":443,"_396":32,"_444":32,"_42":430,"_445":446,"_447":448,"_403":114,"_93":449},[1534],{"_438":451,"_93":452},{"_410":1536,"_391":392,"_412":398},{"_455":456,"_429":430,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1538,"_391":392,"_412":398},{"_413":-5,"_462":463,"_42":-5,"_464":1539,"_93":466},[],{"_410":1541,"_391":392,"_412":398},{"_413":1542,"_42":470,"_464":1543,"_93":466},[],[],{"_410":1545,"_391":392,"_412":398},{"_429":474,"_431":475,"_93":433},{"_410":1547,"_391":392,"_412":398},{"_455":1548,"_396":479,"_104":-5,"_42":474,"_480":-5,"_481":1549,"_483":484,"_403":114,"_485":484,"_93":486},{"_311":491,"_313":492},{"_487":-5,"_413":1550,"_489":1551},[1552],{"_311":491,"_313":492},{"_93":46,"_46":494},{"_410":1554,"_391":392,"_412":398},{"_455":497,"_429":474,"_42":-5,"_182":484,"_458":498,"_93":459},{"_410":1556,"_391":392,"_412":398},{"_436":501,"_438":502,"_440":1557,"_442":443,"_396":504,"_444":32,"_42":505,"_445":506,"_447":448,"_403":114,"_93":449},[1558],{"_438":508,"_93":452},{"_410":1560,"_391":392,"_412":398},{"_429":505,"_431":511,"_93":433},{"_410":1562,"_391":392,"_412":398},{"_455":514,"_429":505,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1564,"_391":392,"_412":398},{"_436":517,"_438":518,"_440":1565,"_442":443,"_396":520,"_444":32,"_42":521,"_445":522,"_447":448,"_403":114,"_93":449},[1566],{"_438":524,"_93":452},{"_410":1568,"_391":392,"_412":398},{"_429":521,"_431":527,"_93":433},{"_410":1570,"_391":392,"_412":398},{"_455":530,"_429":521,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1572,"_391":392,"_412":398},{"_413":-5,"_462":533,"_42":-5,"_464":1573,"_93":466},[1574],{"_46":536,"_93":537},{"_410":1576,"_391":392,"_412":398},{"_413":1577,"_42":541,"_464":1578,"_93":466},[],[536],{"_410":1580,"_391":392,"_412":398},{"_436":545,"_438":546,"_440":1581,"_442":443,"_396":548,"_444":549,"_42":550,"_445":551,"_447":448,"_403":552,"_93":449},[1582],{"_438":554,"_93":452},{"_410":1584,"_391":392,"_412":398},{"_429":557,"_431":558,"_93":433},{"_410":1586,"_391":392,"_412":398},{"_455":561,"_429":557,"_42":-5,"_182":562,"_458":-5,"_93":459},{"_410":1588,"_391":392,"_412":398},{"_429":565,"_431":566,"_93":433},{"_410":1590,"_391":392,"_412":398},{"_455":561,"_429":565,"_42":-5,"_182":562,"_458":-5,"_93":459},{"_410":1592,"_391":392,"_412":398},{"_429":571,"_431":572,"_93":433},{"_410":1594,"_391":392,"_412":398},{"_455":561,"_429":571,"_42":-5,"_182":562,"_458":-5,"_93":459},{"_410":1596,"_391":392,"_412":398},{"_429":550,"_431":577,"_93":433},{"_410":1598,"_391":392,"_412":398},{"_455":580,"_429":550,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1600,"_391":392,"_412":398},{"_429":583,"_182":-5,"_431":584,"_93":585},{"_410":1602,"_391":392,"_412":398},{"_588":1603,"_42":583,"_403":114,"_93":590},[1604],{"_323":592,"_9":1605,"_162":594},{"_595":-5,"_93":596},{"_410":1607,"_391":392,"_412":398},{"_429":583,"_42":-5,"_599":600,"_182":601,"_403":114,"_93":602},{"_410":1609,"_391":392,"_412":398},{"_413":-5,"_462":605,"_42":-5,"_464":1610,"_93":466},[1611],{"_46":608,"_93":537},{"_410":1613,"_391":392,"_412":398},{"_413":1614,"_42":612,"_464":1615,"_93":466},[],[608],{"_410":1617,"_391":392,"_412":398},{"_429":616,"_431":617,"_93":433},{"_410":1619,"_391":392,"_412":398},{"_436":620,"_438":621,"_440":1620,"_442":443,"_396":32,"_444":32,"_42":616,"_445":623,"_447":448,"_403":114,"_93":449},[1621],{"_438":625,"_182":626,"_162":594,"_93":627},{"_410":1623,"_391":392,"_412":398},{"_455":630,"_429":616,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1625,"_391":392,"_412":398},{"_429":633,"_431":634,"_93":433},{"_410":1627,"_391":392,"_412":398},{"_436":637,"_438":638,"_440":1628,"_442":443,"_396":32,"_444":32,"_42":633,"_445":640,"_447":448,"_403":114,"_93":449},[1629],{"_438":642,"_93":452},{"_410":1631,"_391":392,"_412":398},{"_455":645,"_429":633,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1633,"_391":392,"_412":398},{"_429":648,"_431":649,"_93":433},{"_410":1635,"_391":392,"_412":398},{"_436":652,"_438":653,"_440":1636,"_442":443,"_396":32,"_444":32,"_42":648,"_445":655,"_447":448,"_403":114,"_93":449},[1637],{"_438":657,"_93":452},{"_410":1639,"_391":392,"_412":398},{"_455":660,"_429":648,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1641,"_391":392,"_412":398},{"_413":-5,"_462":663,"_42":-5,"_464":1642,"_93":466},[],{"_410":1644,"_391":392,"_412":398},{"_413":1645,"_42":668,"_464":1646,"_93":466},[],[],{"_410":1648,"_391":392,"_412":398},{"_413":1649,"_42":673,"_93":674},[1650],{"_46":676,"_677":1651,"_93":46},[],{"_410":1653,"_391":392,"_412":398},{"_413":1654,"_415":-5,"_42":-5,"_416":-5,"_97":324,"_93":418},[1655],{"_46":676,"_93":683},{"_410":1657,"_391":392,"_412":398},{"_413":1658,"_415":-5,"_42":-5,"_416":-5,"_97":324,"_93":418},[1659,1660],{"_46":690,"_93":683},{"_46":689,"_93":683},{"_410":1662,"_391":392,"_412":398},{"_413":1663,"_415":-5,"_42":-5,"_416":-5,"_97":694,"_93":418},[1664,1665],{"_46":698,"_93":683},{"_46":697,"_93":683},{"_391":392,"_88":1667},{"_104":-5,"_42":398,"_399":1668,"_401":402,"_403":703},[],{"_403":1670,"_391":392},{"_706":1671,"_93":708},[],{"_711":1673},{"_713":-5,"_714":-5,"_715":716,"_717":402,"_442":443,"_718":15,"_719":-5,"_720":-5,"_42":392,"_721":722,"_182":-5,"_162":723,"_724":210,"_447":725,"_403":1674,"_78":1675,"_728":402},{"_93":407},[],[],[1678],{"_42":733,"_734":1679,"_736":737,"_738":737,"_413":1680,"_403":740,"_415":-5,"_741":32,"_742":1681,"_744":745,"_746":-5},{"_97":324,"_182":-5,"_742":1685},{"_751":46,"_752":1684},{"_747":1682},{"_749":1683},[],[754],{},{"_93":418,"_97":94,"_413":1697},{"_93":787,"_788":1692},{"_93":764,"_765":491,"_766":767,"_768":1689,"_770":-5},{"_93":768,"_771":443,"_129":130,"_772":-5,"_323":773,"_774":1690,"_776":327,"_777":778,"_779":32,"_780":781,"_782":1691},{"_784":785,"_786":-5},[],[1693],{"_162":791,"_792":-5,"_793":1694,"_795":-5},[1695],{"_797":327,"_798":799,"_413":1696,"_801":59},[802,210,803,804,805,806,807,210,808,809,810,811,812,813,814,815,816,817,818,819,210,820,210,210,821,822,823,824,825,826,827,210,828,829,830,831,832,833,834,835,836,837,838,839,840,841,842,843,844,845,846,847,848,849,850,851,852,853,210,854,855,856,857,858,859,860,861,862,863,864,865,866,867,868,869,870,871,872,867,873,869,870,871,874,875,876,877,878,879,880,881,869,870,882,883,210,884,885,886,887,888,210,889,890,891,892,893,894,895,896,897,898,899,900,901,902,903,904,905,906,907,863,908,210,909,910,911,210,912,913,914,867,915,916,870,210,917,918,919,920,921,210,922,923,924,925,926,210,927,928,929,930,931,932,933,934,935,936,937,938,210,939,924,940,941,942,943,944,210,945,946,947,210,948,949,210,950,951,952,953,863,210,954,955,956,957,210,958,829,832,959,960,961,962,963,964,965,966,967,968,969,970,971,893,972,973,974,975,976,977,978,979,970,920,210,980,981,982,983,210,984,853,985,986,987,988,989,990,991,992,210,993,994,995,996,997,210,998,896,999,1000,1001,1002,870,1003,1004,1005,1006,1007,1008,1009,1010,1011,1012,1013,1014,1015,1016,1017,1018,1019,1020,1021,1022,896,210,1023,892,1024,896,986,987,988,989,990,1025,992,1026,896,994,1027,896,893,1028,1029,979,1030,1031,992,1017,1032,896,210,1033,1034,1035,1036,1017,1037,210,1038,1039,1040,1041,893,1042,1043,1044,979,1045,1046,1047,979,1048,1049,1050,1051,979,1052,1053,1054,1055,898,1056,1057,992,210,1058,1059,1060,1061,1062,1063,1064,1065,1066,210,1067,1068,1069,1070,1071,874,1072,1073,1074,1075,1076,1077,979,870,1078,1079,1080,1081,1082,210,1083,1084,1085,1086,210,1087,1088,1089,1090,1064,1091,1092,1093,1094,865,1095,1094,865,1096,1097,967,1098,1099,1100,1101,1102,1103,979,898,1104,210,1105,1106,1107,1108,1109,978,1110,979,1111,1112,978,1113,979,898,1104,1114,1115,1116,1117,869,1118,870,867,1119,869,1120,870,1094,865,210,866,1121,1094,865,1122,210,1123,1124,964,1125,210,1126,1127,1128,1064,1129,1130,1131,1132,863,1133,1134,1135,1136,987,1137,1138,1139,1140,897,1109,978,1141,979,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,863,1158,210,1159,1160,1161,1162,210,1163,1164,1165,1064,1166,1167,1168,1169,1170,870,1171,1172,1173,1174,870,878,1175,869,1120,1176,870,1177,1178,1179,1180,870,1168,1181,1182,870,1171,1172,1173,1174,870,878,1183,869,1120,1176,870,1177,1184,1185,1168,1186,1182,870,1171,1172,1173,1174,870,878,1187,1188,869,1120,1176,1189,870,1177,1190,1191,1192,870,1171,1193,869,1194,1195,870,1196,1197,1198,878,1199,1200,869,1120,1176,1201,870,1202,1203,1204,1205,1048,1206,1207,979,1208,1209,1210,1211,1212,863,1213,1214,210,1215,1216,210,1217,1218,964,1219,874,1220,1221,1222,1223,1224,210,1225,1226,1227,1228,1143,1153,1154,1229,1230,863,210,1231,1232,1233,1234,1235,1236,1237,1235,1238,1239,1240,1241,1242,1235,1243,1244,874,875,876,877,878,1245,1246,869,870,1235,1247,1248,1249,863,1250,210,1251,1252,1253,1254,1255,1256,1257,1258,1259,975,1260,979,1261,210,1262,1236,1263,1264,210,1265,1266,1267,969,896,1268,1017,1269,1270,1017,1271,1272,1273,975,1274,1275,1276,979,1017,1277,1278,1279,1280,1281,979,1098,1282,1100,1101,1102,1283,979,1284,1017,1285,1098,1282,1100,1101,1102,1103,979,897,987,1286,1287,1288,1289,1290,1291,1292,1293,992,1294,1295,920,1296,210,1297,1298,1299,1300,210,1301,1295,1302,1296,210,1303,1304,1143,1305,1306,1307,1308,863,210,1309,1310,1143,1311,874,1312,1313,1314,893,1315,1316,1317,1318,210,1319,1320,893,1321,1322,1323,893,1324,1030,1017,210,1325,1326,892,893,1327,895,896,1094,1328,1329,210,1330,1331,1267,901,1267,893,1332,1032,1317,902,210,1333,1334,1335,1336,1337,210,1338,1339,1340,1341,975,1342,1343,1344,1345,979,893,1346,1030,1347,1348,1289,1349,1350,1351,1352,1293,1353,1354,1355,1356,987,1357,1358,1359,1293,989,1360,1361,1362,1007,1363,1009,1364,1365,1366,1367,1368,1032,1223,1322,1369,210,1370,1371,867,1372,1373,870,1374,893,1375,1322,1376,1377,1378,903],[1698,1699,1700],{"_751":46,"_46":1387},{"_751":1384,"_162":791,"_797":1385,"_798":1386},{"_751":46,"_46":1383},[1957,1958,1959],[],{"_756":757,"_46":758,"_759":760},{"_730":1948},{"_334":1947},{"_334":1736},{"_303":304,"_295":305,"_306":307,"_308":15,"_309":59,"_310":15,"_311":312,"_313":314,"_315":267,"_316":128,"_317":318,"_319":130,"_320":321,"_322":-5,"_323":-5,"_324":1735,"_326":327,"_328":327,"_329":330,"_331":332},{"_42":124,"_194":195,"_196":197,"_198":15,"_199":200,"_201":202,"_203":1724,"_205":-5,"_206":-5,"_207":1725,"_209":210,"_211":210,"_212":1726,"_214":1727,"_216":1728,"_218":-5,"_219":220,"_221":222,"_223":224,"_225":1729,"_55":-5,"_120":227,"_228":1730,"_230":1731,"_232":233,"_234":15,"_235":15},{"_134":1717},[1711,1712,1713,1714,1715,1716],{"_149":172,"_151":166,"_153":167,"_155":164,"_157":173,"_159":160,"_161":32,"_162":-5},{"_149":171,"_151":166,"_153":167,"_155":164,"_157":168,"_159":160,"_161":32,"_162":-5},{"_149":169,"_151":166,"_153":167,"_155":164,"_157":170,"_159":160,"_161":32,"_162":-5},{"_149":165,"_151":166,"_153":167,"_155":164,"_157":168,"_159":160,"_161":32,"_162":-5},{"_149":163,"_151":152,"_153":154,"_155":164,"_157":158,"_159":160,"_161":32,"_162":-5},{"_149":150,"_151":152,"_153":154,"_155":156,"_157":158,"_159":160,"_161":32,"_162":-5},[1718,1719,1720],{"_178":1723,"_180":191},{"_178":1722,"_180":187},{"_178":1721,"_180":181},{"_182":183,"_93":184,"_120":185},{"_182":188,"_93":184,"_120":189},{"_182":192,"_93":184,"_120":193},{"_297":298,"_299":-5,"_300":-5,"_301":-5,"_302":-5},[257],{"_257":1732},{"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256},{},[],{"_238":59},{"_236":59,"_237":210},{"_42":259,"_182":260,"_261":1733,"_263":197,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":64,"_275":15,"_276":-5,"_277":-5,"_278":-5,"_279":-5,"_280":-5,"_281":-5,"_161":282,"_283":-5,"_55":1734},{"_289":290,"_42":291,"_93":292,"_293":294,"_295":296},{"_285":15,"_286":15,"_287":15,"_288":15},{"_289":290,"_182":290,"_333":-5,"_293":294,"_42":291},[1737,1738,1739,1740,1741,1742,1743,1744,1745,1746,1747,1748,1749,1750,1751,1752,1753,1754,1755,1756,1757,1758,1759,1760,1761,1762,1763,1764,1765,1766,1767,1768,1769,1770,1771,1772,1773,1774,1775,1776,1777,1778,1779,1780,1781,1782,1783,1784,1785,1786,1787,1788],{"_155":709,"_389":1943},{"_155":404,"_389":1940},{"_155":699,"_389":1937},{"_155":408,"_389":1932},{"_155":408,"_389":1927},{"_155":408,"_389":1923},{"_155":422,"_389":1918},{"_155":422,"_389":1914},{"_155":408,"_389":1911},{"_155":408,"_389":1909},{"_155":422,"_389":1905},{"_155":408,"_389":1903},{"_155":408,"_389":1901},{"_155":422,"_389":1897},{"_155":408,"_389":1895},{"_155":408,"_389":1893},{"_155":422,"_389":1889},{"_155":408,"_389":1887},{"_155":422,"_389":1883},{"_155":408,"_389":1879},{"_155":408,"_389":1877},{"_155":422,"_389":1872},{"_155":408,"_389":1870},{"_155":408,"_389":1868},{"_155":408,"_389":1866},{"_155":408,"_389":1864},{"_155":408,"_389":1862},{"_155":408,"_389":1860},{"_155":408,"_389":1858},{"_155":408,"_389":1856},{"_155":408,"_389":1854},{"_155":422,"_389":1850},{"_155":422,"_389":1846},{"_155":408,"_389":1842},{"_155":408,"_389":1840},{"_155":408,"_389":1838},{"_155":422,"_389":1834},{"_155":408,"_389":1832},{"_155":408,"_389":1830},{"_155":422,"_389":1826},{"_155":408,"_389":1824},{"_155":422,"_389":1817},{"_155":408,"_389":1815},{"_155":422,"_389":1811},{"_155":408,"_389":1808},{"_155":408,"_389":1806},{"_155":422,"_389":1802},{"_155":408,"_389":1800},{"_155":422,"_389":1798},{"_155":408,"_389":1794},{"_155":404,"_389":1792},{"_155":388,"_389":1789},{"_391":392,"_88":1790},{"_394":395,"_396":397,"_104":-5,"_42":398,"_399":1791,"_401":402,"_403":114},[],{"_403":1793,"_391":392},{"_93":407},{"_410":1795,"_391":392,"_412":398},{"_413":1796,"_415":-5,"_42":-5,"_416":417,"_97":94,"_93":418},[1797],{"_46":420,"_93":421},{"_410":1799,"_391":392,"_412":398},{"_42":425,"_416":417,"_46":420,"_93":426},{"_410":1801,"_391":392,"_412":398},{"_429":430,"_431":432,"_93":433},{"_410":1803,"_391":392,"_412":398},{"_436":437,"_438":439,"_440":1804,"_442":443,"_396":32,"_444":32,"_42":430,"_445":446,"_447":448,"_403":114,"_93":449},[1805],{"_438":451,"_93":452},{"_410":1807,"_391":392,"_412":398},{"_455":456,"_429":430,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1809,"_391":392,"_412":398},{"_413":-5,"_462":463,"_42":-5,"_464":1810,"_93":466},[],{"_410":1812,"_391":392,"_412":398},{"_413":1813,"_42":470,"_464":1814,"_93":466},[],[],{"_410":1816,"_391":392,"_412":398},{"_429":474,"_431":475,"_93":433},{"_410":1818,"_391":392,"_412":398},{"_455":1819,"_396":479,"_104":-5,"_42":474,"_480":-5,"_481":1820,"_483":484,"_403":114,"_485":484,"_93":486},{"_311":491,"_313":492},{"_487":-5,"_413":1821,"_489":1822},[1823],{"_311":491,"_313":492},{"_93":46,"_46":494},{"_410":1825,"_391":392,"_412":398},{"_455":497,"_429":474,"_42":-5,"_182":484,"_458":498,"_93":459},{"_410":1827,"_391":392,"_412":398},{"_436":501,"_438":502,"_440":1828,"_442":443,"_396":504,"_444":32,"_42":505,"_445":506,"_447":448,"_403":114,"_93":449},[1829],{"_438":508,"_93":452},{"_410":1831,"_391":392,"_412":398},{"_429":505,"_431":511,"_93":433},{"_410":1833,"_391":392,"_412":398},{"_455":514,"_429":505,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1835,"_391":392,"_412":398},{"_436":517,"_438":518,"_440":1836,"_442":443,"_396":520,"_444":32,"_42":521,"_445":522,"_447":448,"_403":114,"_93":449},[1837],{"_438":524,"_93":452},{"_410":1839,"_391":392,"_412":398},{"_429":521,"_431":527,"_93":433},{"_410":1841,"_391":392,"_412":398},{"_455":530,"_429":521,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1843,"_391":392,"_412":398},{"_413":-5,"_462":533,"_42":-5,"_464":1844,"_93":466},[1845],{"_46":536,"_93":537},{"_410":1847,"_391":392,"_412":398},{"_413":1848,"_42":541,"_464":1849,"_93":466},[],[536],{"_410":1851,"_391":392,"_412":398},{"_436":545,"_438":546,"_440":1852,"_442":443,"_396":548,"_444":549,"_42":550,"_445":551,"_447":448,"_403":552,"_93":449},[1853],{"_438":554,"_93":452},{"_410":1855,"_391":392,"_412":398},{"_429":557,"_431":558,"_93":433},{"_410":1857,"_391":392,"_412":398},{"_455":561,"_429":557,"_42":-5,"_182":562,"_458":-5,"_93":459},{"_410":1859,"_391":392,"_412":398},{"_429":565,"_431":566,"_93":433},{"_410":1861,"_391":392,"_412":398},{"_455":561,"_429":565,"_42":-5,"_182":562,"_458":-5,"_93":459},{"_410":1863,"_391":392,"_412":398},{"_429":571,"_431":572,"_93":433},{"_410":1865,"_391":392,"_412":398},{"_455":561,"_429":571,"_42":-5,"_182":562,"_458":-5,"_93":459},{"_410":1867,"_391":392,"_412":398},{"_429":550,"_431":577,"_93":433},{"_410":1869,"_391":392,"_412":398},{"_455":580,"_429":550,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1871,"_391":392,"_412":398},{"_429":583,"_182":-5,"_431":584,"_93":585},{"_410":1873,"_391":392,"_412":398},{"_588":1874,"_42":583,"_403":114,"_93":590},[1875],{"_323":592,"_9":1876,"_162":594},{"_595":-5,"_93":596},{"_410":1878,"_391":392,"_412":398},{"_429":583,"_42":-5,"_599":600,"_182":601,"_403":114,"_93":602},{"_410":1880,"_391":392,"_412":398},{"_413":-5,"_462":605,"_42":-5,"_464":1881,"_93":466},[1882],{"_46":608,"_93":537},{"_410":1884,"_391":392,"_412":398},{"_413":1885,"_42":612,"_464":1886,"_93":466},[],[608],{"_410":1888,"_391":392,"_412":398},{"_429":616,"_431":617,"_93":433},{"_410":1890,"_391":392,"_412":398},{"_436":620,"_438":621,"_440":1891,"_442":443,"_396":32,"_444":32,"_42":616,"_445":623,"_447":448,"_403":114,"_93":449},[1892],{"_438":625,"_182":626,"_162":594,"_93":627},{"_410":1894,"_391":392,"_412":398},{"_455":630,"_429":616,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1896,"_391":392,"_412":398},{"_429":633,"_431":634,"_93":433},{"_410":1898,"_391":392,"_412":398},{"_436":637,"_438":638,"_440":1899,"_442":443,"_396":32,"_444":32,"_42":633,"_445":640,"_447":448,"_403":114,"_93":449},[1900],{"_438":642,"_93":452},{"_410":1902,"_391":392,"_412":398},{"_455":645,"_429":633,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1904,"_391":392,"_412":398},{"_429":648,"_431":649,"_93":433},{"_410":1906,"_391":392,"_412":398},{"_436":652,"_438":653,"_440":1907,"_442":443,"_396":32,"_444":32,"_42":648,"_445":655,"_447":448,"_403":114,"_93":449},[1908],{"_438":657,"_93":452},{"_410":1910,"_391":392,"_412":398},{"_455":660,"_429":648,"_42":-5,"_182":457,"_458":-5,"_93":459},{"_410":1912,"_391":392,"_412":398},{"_413":-5,"_462":663,"_42":-5,"_464":1913,"_93":466},[],{"_410":1915,"_391":392,"_412":398},{"_413":1916,"_42":668,"_464":1917,"_93":466},[],[],{"_410":1919,"_391":392,"_412":398},{"_413":1920,"_42":673,"_93":674},[1921],{"_46":676,"_677":1922,"_93":46},[],{"_410":1924,"_391":392,"_412":398},{"_413":1925,"_415":-5,"_42":-5,"_416":-5,"_97":324,"_93":418},[1926],{"_46":676,"_93":683},{"_410":1928,"_391":392,"_412":398},{"_413":1929,"_415":-5,"_42":-5,"_416":-5,"_97":324,"_93":418},[1930,1931],{"_46":690,"_93":683},{"_46":689,"_93":683},{"_410":1933,"_391":392,"_412":398},{"_413":1934,"_415":-5,"_42":-5,"_416":-5,"_97":694,"_93":418},[1935,1936],{"_46":698,"_93":683},{"_46":697,"_93":683},{"_391":392,"_88":1938},{"_104":-5,"_42":398,"_399":1939,"_401":402,"_403":703},[],{"_403":1941,"_391":392},{"_706":1942,"_93":708},[],{"_711":1944},{"_713":-5,"_714":-5,"_715":716,"_717":402,"_442":443,"_718":15,"_719":-5,"_720":-5,"_42":392,"_721":722,"_182":-5,"_162":723,"_724":210,"_447":725,"_403":1945,"_78":1946,"_728":402},{"_93":407},[],[],[1949],{"_42":733,"_734":1950,"_736":737,"_738":737,"_413":1951,"_403":740,"_415":-5,"_741":32,"_742":1952,"_744":745,"_746":-5},{"_97":324,"_182":-5,"_742":1956},{"_751":46,"_752":1955},{"_747":1953},{"_749":1954},[],[754],{},{"_93":418,"_97":94,"_413":1968},{"_93":787,"_788":1963},{"_93":764,"_765":491,"_766":767,"_768":1960,"_770":-5},{"_93":768,"_771":443,"_129":130,"_772":-5,"_323":773,"_774":1961,"_776":327,"_777":778,"_779":32,"_780":781,"_782":1962},{"_784":785,"_786":-5},[],[1964],{"_162":791,"_792":-5,"_793":1965,"_795":-5},[1966],{"_797":327,"_798":799,"_413":1967,"_801":59},[802,210,803,804,805,806,807,210,808,809,810,811,812,813,814,815,816,817,818,819,210,820,210,210,821,822,823,824,825,826,827,210,828,829,830,831,832,833,834,835,836,837,838,839,840,841,842,843,844,845,846,847,848,849,850,851,852,853,210,854,855,856,857,858,859,860,861,862,863,864,865,866,867,868,869,870,871,872,867,873,869,870,871,874,875,876,877,878,879,880,881,869,870,882,883,210,884,885,886,887,888,210,889,890,891,892,893,894,895,896,897,898,899,900,901,902,903,904,905,906,907,863,908,210,909,910,911,210,912,913,914,867,915,916,870,210,917,918,919,920,921,210,922,923,924,925,926,210,927,928,929,930,931,932,933,934,935,936,937,938,210,939,924,940,941,942,943,944,210,945,946,947,210,948,949,210,950,951,952,953,863,210,954,955,956,957,210,958,829,832,959,960,961,962,963,964,965,966,967,968,969,970,971,893,972,973,974,975,976,977,978,979,970,920,210,980,981,982,983,210,984,853,985,986,987,988,989,990,991,992,210,993,994,995,996,997,210,998,896,999,1000,1001,1002,870,1003,1004,1005,1006,1007,1008,1009,1010,1011,1012,1013,1014,1015,1016,1017,1018,1019,1020,1021,1022,896,210,1023,892,1024,896,986,987,988,989,990,1025,992,1026,896,994,1027,896,893,1028,1029,979,1030,1031,992,1017,1032,896,210,1033,1034,1035,1036,1017,1037,210,1038,1039,1040,1041,893,1042,1043,1044,979,1045,1046,1047,979,1048,1049,1050,1051,979,1052,1053,1054,1055,898,1056,1057,992,210,1058,1059,1060,1061,1062,1063,1064,1065,1066,210,1067,1068,1069,1070,1071,874,1072,1073,1074,1075,1076,1077,979,870,1078,1079,1080,1081,1082,210,1083,1084,1085,1086,210,1087,1088,1089,1090,1064,1091,1092,1093,1094,865,1095,1094,865,1096,1097,967,1098,1099,1100,1101,1102,1103,979,898,1104,210,1105,1106,1107,1108,1109,978,1110,979,1111,1112,978,1113,979,898,1104,1114,1115,1116,1117,869,1118,870,867,1119,869,1120,870,1094,865,210,866,1121,1094,865,1122,210,1123,1124,964,1125,210,1126,1127,1128,1064,1129,1130,1131,1132,863,1133,1134,1135,1136,987,1137,1138,1139,1140,897,1109,978,1141,979,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,863,1158,210,1159,1160,1161,1162,210,1163,1164,1165,1064,1166,1167,1168,1169,1170,870,1171,1172,1173,1174,870,878,1175,869,1120,1176,870,1177,1178,1179,1180,870,1168,1181,1182,870,1171,1172,1173,1174,870,878,1183,869,1120,1176,870,1177,1184,1185,1168,1186,1182,870,1171,1172,1173,1174,870,878,1187,1188,869,1120,1176,1189,870,1177,1190,1191,1192,870,1171,1193,869,1194,1195,870,1196,1197,1198,878,1199,1200,869,1120,1176,1201,870,1202,1203,1204,1205,1048,1206,1207,979,1208,1209,1210,1211,1212,863,1213,1214,210,1215,1216,210,1217,1218,964,1219,874,1220,1221,1222,1223,1224,210,1225,1226,1227,1228,1143,1153,1154,1229,1230,863,210,1231,1232,1233,1234,1235,1236,1237,1235,1238,1239,1240,1241,1242,1235,1243,1244,874,875,876,877,878,1245,1246,869,870,1235,1247,1248,1249,863,1250,210,1251,1252,1253,1254,1255,1256,1257,1258,1259,975,1260,979,1261,210,1262,1236,1263,1264,210,1265,1266,1267,969,896,1268,1017,1269,1270,1017,1271,1272,1273,975,1274,1275,1276,979,1017,1277,1278,1279,1280,1281,979,1098,1282,1100,1101,1102,1283,979,1284,1017,1285,1098,1282,1100,1101,1102,1103,979,897,987,1286,1287,1288,1289,1290,1291,1292,1293,992,1294,1295,920,1296,210,1297,1298,1299,1300,210,1301,1295,1302,1296,210,1303,1304,1143,1305,1306,1307,1308,863,210,1309,1310,1143,1311,874,1312,1313,1314,893,1315,1316,1317,1318,210,1319,1320,893,1321,1322,1323,893,1324,1030,1017,210,1325,1326,892,893,1327,895,896,1094,1328,1329,210,1330,1331,1267,901,1267,893,1332,1032,1317,902,210,1333,1334,1335,1336,1337,210,1338,1339,1340,1341,975,1342,1343,1344,1345,979,893,1346,1030,1347,1348,1289,1349,1350,1351,1352,1293,1353,1354,1355,1356,987,1357,1358,1359,1293,989,1360,1361,1362,1007,1363,1009,1364,1365,1366,1367,1368,1032,1223,1322,1369,210,1370,1371,867,1372,1373,870,1374,893,1375,1322,1376,1377,1378,903],[1969,1970,1971],{"_751":46,"_46":1387},{"_751":1384,"_162":791,"_797":1385,"_798":1386},{"_751":46,"_46":1383},[1974,1975,1976,1977,1978],{"_1397":1398,"_263":197,"_1399":304,"_274":-5,"_771":257,"_1400":-5,"_1401":1402,"_1403":1404,"_1405":-5,"_1406":-5,"_1407":1408,"_1409":15,"_1410":59,"_1411":54,"_1412":15},{"_93":418,"_97":324,"_413":1979},{"_311":312,"_313":314,"_1424":318,"_1425":130,"_320":-5,"_93":1426},{"_93":1418,"_313":1423,"_162":-5,"_1420":-5,"_1421":-5},{"_93":1418,"_313":1422,"_162":-5,"_1420":-5,"_1421":-5},{"_93":1418,"_313":1419,"_162":-5,"_1420":-5,"_1421":-5},[1980],{"_751":46,"_46":1429},"task_e_6a35f2f33a0c8324a501c5163242a199",1781920499.227003,"GitHub Mention: refactor(queue): снизить сложность _run_single_worker F(54)→C (#922)","has_generated_title","has_unread_turn","denormalized_metadata",{"_2012":32,"_2013":2014,"_2015":-5,"_2016":-5,"_2006":2017,"_2018":-5,"_2019":-5,"_2020":-5,"_2021":-5},"task_status_display",{"_2000":2001,"_2002":197,"_131":128,"_2003":-5,"_2004":764},"creator_workspace","external_pull_requests",[1993],{"_42":1994,"_1995":84,"_1996":1997,"_1998":130},"github-1173202292-927","assistant_turn_id","pull_request",{"_303":304,"_295":305,"_306":307,"_308":15,"_309":59,"_310":15,"_311":312,"_313":314,"_315":267,"_316":128,"_317":318,"_319":130,"_320":321,"_322":-5,"_323":-5,"_324":1999,"_326":327,"_328":327,"_329":330,"_331":332},"codex_updated_sha",{"_289":290,"_182":290,"_333":-5,"_293":294,"_42":291},"latest_turn_status_display",{"_2005":84,"_113":114,"_2006":2007,"_95":2008,"_2009":-5,"_2010":-5,"_2011":764,"_115":-5},"environment_label","fix_task_id","initial_intent","turn_id","diff_stats",{"_776":327,"_777":778,"_779":32},[],"image_asset_pointer_citations","issue_counts","intent","num_follow_ups","repo_name_map",{},"last_user_turn_created_at","last_turn_status",{"_776":-5,"_777":-5,"_779":-5},"last_pushed_turn_id","start_branch_name","pushed_branch_name","cached_pull_request_data","dd",{"_2033":2034,"_2035":2036},"disablePrefetch","shouldPrefetchAccount","shouldPrefetchUser","shouldPrefetchSystemHints","promoteCss","disableSSR","stripModulepreloadImports","statsigGateEvaluationsPromise",["P",2032],"traceId","15268686495517987377","traceTime",1781940313370]