bulk-cdk-core-load/io.airbyte.cdk.load.task.internal/UpdateCheckpointsTask

UpdateCheckpointsTask

@Singleton
@Secondary
class UpdateCheckpointsTask(syncManager: SyncManager, checkpointManager: CheckpointManager, checkpointMessageQueue: MessageQueue<Reserved<CheckpointMessageWrapped>>) : Task

Constructors

Link copied to clipboard
constructor(syncManager: SyncManager, checkpointManager: CheckpointManager, checkpointMessageQueue: MessageQueue<Reserved<CheckpointMessageWrapped>>)

Properties

Link copied to clipboard
val log: KLogger
Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()