SyncGateSimpleEarnWorkflow

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

Input (models.SyncGateSimpleEarnInput):

• page_limit
• max_pages
• search_coin

Output (models.SyncGateSimpleEarnResult):

• snapshot_at
• projects_seen
• projects_upserted
• subpools_seen
• subpools_upserted
• quarantine_rows

Поведение

• запускает одну activity SyncGateSimpleEarnSnapshot;
• retry policy: up to 3 attempts with exponential backoff;
• non-retryable: gate_simple_earn_access_denied.

Связи

• Activity: SyncGateSimpleEarnSnapshot
• API: Gate Simple Earn Pipeline

Manual Run

docker compose exec -T temporal-admin-tools temporal workflow start \
  --address temporal:7233 --namespace default --task-queue default \
  --type SyncGateSimpleEarnWorkflow \
  --workflow-id sync-gate-simple-earn-manual-$(date +%s) \
  --input '{}'

Verification

• Tables: fct_gate_simple_earn_snapshot, fct_gate_simple_earn_subpool_snapshot, fct_gate_simple_earn_response_snapshot, fct_gate_simple_earn_quarantine, fct_gate_simple_earn_5min, fct_gate_simple_earn_daily
• Логи: gate_simple_earn_mapping_coverage, gate simple earn market list request failed