ScrapeBingXLaunchpoolWorkflow
Purpose
Оркестрация scraping BingX Launchpool через Playwright activity.
Код: internal/worker/workflows/scrape_bingx_launchpool.go
Input / Output
Input (models.ScrapeBingXLaunchpoolParams):
- include_details (optional, default true)
Output: []models.BingXLaunchpoolProject.
Called Activities / Children
- Activity:
ScrapeBingXLaunchpoolActivity - Child workflows: нет
Retry / Failure Behavior
- Activity timeout:
5m - Workflow-level retry policy явно не задана.
- Ошибка activity завершает workflow с
failed.
Manual Run
docker compose exec -T temporal temporal workflow start \
--address temporal:7233 --namespace default --task-queue default \
--type ScrapeBingXLaunchpoolWorkflow \
--workflow-id scrape-bingx-launchpool-manual-$(date +%s) \
--input '{"include_details":true}'
Related Tables / Logs
- DB write: отсутствует
- Логи activity содержат этапы обхода Cloudflare, API interception и fallback.
- Для записи snapshots в БД используется отдельный workflow:
SyncBingXLaunchpoolWorkflow.