bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.task.implementor/SetupTask

SetupTask

class SetupTask(destination: DestinationWriter, taskLauncher: DestinationTaskLauncher) : Task(source)

Wraps @DestinationWriter.setup and starts the open stream tasks.

Constructors

constructor(destination: DestinationWriter, taskLauncher: DestinationTaskLauncher)

Properties

terminalCondition

open override val terminalCondition: TerminalCondition

Functions

open suspend override fun execute()