Function TrackSyncCompleted

cli/internal/analytics/client.go:186–218

(ctx context.Context, invocationUUID uuid.UUID, event SyncFinishedEvent)

}

func TrackSyncCompleted(ctx context.Context, invocationUUID uuid.UUID, event SyncFinishedEvent) {
	if client == nil {
		return
	}

	details := getSyncEventDetails(ctx)
	if details == nil {
		return
	}

	if details.isCurrentTeamInternal {
		return
	}

	status := "success"
	if event.AbortedDueToError != nil {
		status = "error"
	}

	props := getSyncCommonProps(invocationUUID, event.SyncStartedEvent, details).
		Set("duration", event.Duration).
		Set("status", status).
		Set("total_rows", event.ResourceCount).
		Set("errors", event.Errors).
		Set("warnings", event.Warnings).
		Set("aborted_due_to_error", event.AbortedDueToError)

	_ = client.Enqueue(rudderstack.Track{
		UserId:     details.user.ID.String(),
		Event:      "sync_run_completed",
		Properties: props,
	})
}

type InitEvent struct {
	Source         string