ExPipedriveOban.SyncWorker (ex_pipedrive_oban v0.1.0)

Copy Markdown View Source

Cursor-aware Oban worker for Pipedrive list endpoints.

Job args:

  • "source" — module implementing ExPipedriveOban.Source
  • "tenant_id" — opaque tenant key (unique with "resource")
  • "resource" — "deals" / "persons" / "organizations" / "activities"
  • "cursor" — optional v2 cursor to resume
  • "limit" — optional page size
  • "list_opts" — optional string-key map of extra list_page/2 options

Kickoff jobs are unique per tenant + resource. Continuation pages insert with unique: false so the next cursor is not treated as a duplicate kickoff.