SyncBybitEasyEarnWorkflow

Снимает snapshot Bybit Easy Earn через API и записывает факты в Timescale.

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

Input (models.SyncBybitEasyEarnInput):

• page_limit optional, default 10
• max_pages optional, default 30

Output (models.SyncBybitEasyEarnResult):

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

Execution

• Activity: SyncBybitEasyEarnSnapshot
• Non-retryable: bybit_easy_earn_access_denied

Manual run:

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

Verification

• Tables: fct_bybit_easy_earn_snapshot, fct_bybit_easy_earn_subpool_snapshot, fct_bybit_easy_earn_response_snapshot, fct_bybit_easy_earn_quarantine, fct_bybit_easy_earn_5min, fct_bybit_easy_earn_daily
• Логи: bybit_easy_earn_mapping_coverage, bybit easy earn coins request failed, bybit easy earn product list request failed