SyncKuCoinEarnWorkflow

Снимает snapshot KuCoin Earn All Products через confirmed web API и записывает факты в Timescale.

Input

Input (models.SyncKuCoinEarnInput):

• keyword — optional search keyword
• layer — overview depth, default 3
• order_by — optional ordering selector
• exclude_advanced_group_apr — default true
• lang — default en_US

Output

Output (models.SyncKuCoinEarnResult):

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

Activity

• SyncKuCoinEarnSnapshot

Manual Run

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