SyncBingXXPoolWorkflow

Purpose

Снимает snapshot BingX XPool (источник через Playwright scraping) и записывает факты в Timescale.

Код: internal/worker/workflows/sync_bingx_xpool.go

Input / Output

Input (models.SyncBingXXPoolInput): - include_details (optional, default true)

Output (models.SyncBingXXPoolResult): - snapshot_at - projects_seen, projects_upserted - subpools_seen, subpools_upserted - quarantine_rows - errors[], has_errors

Called Activities / Children

• Activity: SyncBingXXPoolSnapshot
• Child workflows: нет

Retry / Failure Behavior

• Activity timeout: 10m
• Retry: max_attempts=3
• Ошибка scraping/ingest завершает workflow с failed.

Manual Run

docker compose exec -T temporal temporal workflow start \
  --address temporal:7233 --namespace default --task-queue default \
  --type SyncBingXXPoolWorkflow \
  --workflow-id sync-bingx-xpool-manual-$(date +%s) \
  --input '{"include_details":true}'

Related Tables / Logs

• Tables: fct_bingx_xpool_snapshot, fct_bingx_xpool_subpool_snapshot, fct_bingx_xpool_response_snapshot, fct_bingx_xpool_quarantine, fct_bingx_xpool_5min, fct_bingx_xpool_daily
• Логи: bingx_xpool_mapping_coverage, bingx xpool scrape failed