SyncKuCoinLaunchpoolWorkflow

Purpose

Снимает snapshot KuCoin GemPool (launchpool) и записывает факты в Timescale.

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

Input / Output

Input (models.SyncKuCoinLaunchpoolInput): - include_current (optional, default true) - include_history (optional, default true) - history_page_size (optional, default 20, max 50) - max_history_pages (optional, default 10)

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

Called Activities / Children

• Activity: SyncKuCoinLaunchpoolSnapshot
• Child workflows: нет

Retry / Failure Behavior

• Activity timeout: 5m
• Retry: max_attempts=3
• Non-retryable error types: kucoin_access_denied

Manual Run

docker compose exec -T temporal temporal workflow start \
  --address temporal:7233 --namespace default --task-queue default \
  --type SyncKuCoinLaunchpoolWorkflow \
  --workflow-id sync-kucoin-launchpool-manual-$(date +%s) \
  --input '{"include_current":true,"include_history":true,"history_page_size":20,"max_history_pages":10}'

Related Tables / Logs

• Tables: fct_kucoin_launchpool_snapshot, fct_kucoin_launchpool_subpool_snapshot, fct_kucoin_launchpool_response_snapshot, fct_kucoin_launchpool_quarantine, fct_kucoin_launchpool_5min, fct_kucoin_launchpool_daily
• Логи: kucoin_launchpool_mapping_coverage, kucoin launchpool request failed