TeardownTask

class TeardownTask(checkpointManager: CheckpointManager, syncManager: SyncManager, destination: DestinationWriter, taskLauncher: DestinationTaskLauncher) : Task

Wraps @DestinationWriter.teardown and stops the task launcher.

TODO: Report teardown-complete and let the task launcher decide what to do next.

Constructors

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

Properties

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

Functions

Link copied to clipboard
open suspend override fun execute()