Member Junction
    Preparing search index...
    IntegrationProgressEventType:
        | "run.start"
        | "run.complete"
        | "run.fail"
        | "run.cancel"
        | "run.resumed"
        | "stage.start"
        | "stage.complete"
        | "stage.error"
        | "records.batch.start"
        | "records.batch.complete"
        | "record.error"
        | "warning"
        | "progress.heartbeat"
        | "checkpoint"
        | "external.call.start"
        | "external.call.complete"
        | "external.call.retry"
        | "transform.applied"
        | "discovery.object.added"
        | "discovery.field.added"
        | "pk.classifier.invoked"
        | "pk.classifier.result"
        | "entity.generated"
        | "entity.skipped-no-pk"

    Event types in the progress.jsonl stream.

    Type Declaration

    • "run.start"

      Run started.

    • "run.complete"

      Run terminated successfully.

    • "run.fail"

      Run terminated with failure.

    • "run.cancel"

      Run cancelled mid-flight by a user/system abort (not a failure, not a clean completion).

    • "run.resumed"

      Run resumed from a prior checkpoint after a kill/restart.

    • "stage.start"

      A named stage within the run started.

    • "stage.complete"

      A named stage within the run completed.

    • "stage.error"

      A named stage within the run errored (run may continue or fail).

    • "records.batch.start"

      A batch of records is about to be processed (sync paths).

    • "records.batch.complete"

      A batch of records has been processed.

    • "record.error"

      A single record errored within a batch.

    • "warning"

      A non-fatal warning surfaced during the run. Carries a structured {stage, code, message, data} payload (see SyncWarning). Distinct from stage.error/record.error: a warning never fails the run, it is aggregated separately into the result's warnings[] rollup.

    • "progress.heartbeat"

      Long-running progress with no record-level granularity.

    • "checkpoint"

      Resumable checkpoint. Carries resumableState — the subsystem-specific shape needed for the run to resume from this exact point. On restart, the resumption engine reads the latest checkpoint event for any in-flight run and hands the resumableState back to the originating service.

    • "external.call.start"

      An outbound API call started (vendor-API debugging, esp. GraphQL).

    • "external.call.complete"

      An outbound API call completed.

    • "external.call.retry"

      An outbound API call retrying after transient failure.

    • "transform.applied"

      TransformRecord (or equivalent) reshaped a record.

    • "discovery.object.added"

      Discovery added a new IntegrationObject row.

    • "discovery.field.added"

      Discovery added a new IntegrationObjectField row.

    • "pk.classifier.invoked"

      PK classifier invoked for an object.

    • "pk.classifier.result"

      PK classifier returned a verdict.

    • "entity.generated"

      An MJ entity was generated for an IO row that has a PK.

    • "entity.skipped-no-pk"

      An IO row was skipped from entity generation because it lacks a PK.