FailSyncTask

class FailSyncTask(taskLauncher: DestinationTaskLauncher, destinationWriter: DestinationWriter, exception: Exception, syncManager: SyncManager, checkpointManager: CheckpointManager) : Task

FailSyncTask is a task that is executed only when the destination itself fails during a sync. If the sync is failed by upstream (e.g. an incomplete stream message is received), we do not call this task. It is responsible for cleaning up resources and reporting the failure.

Constructors

Link copied to clipboard
constructor(taskLauncher: DestinationTaskLauncher, destinationWriter: DestinationWriter, exception: Exception, syncManager: SyncManager, checkpointManager: CheckpointManager)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()