analytics-catalog-domain/me.ahoo.wow.analytics.catalog.domain.source/Source/onSync

onSync

@OnCommand(produces = [WowEnrichmentAdopted::class, WowEnrichmentRefused::class, WowEnrichmentLost::class, SourceTableChanged::class, SourceTableMissing::class])

suspend fun onSync(command: Command<SyncSource>, catalog: WarehouseCatalog, writers: TrustedWriters): Decision