Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.task/TaskScopeProvider

TaskScopeProvider

@Singleton

class TaskScopeProvider(config: DestinationConfiguration)

Constructors

TaskScopeProvider

constructor(config: DestinationConfiguration)

Types

data class AnnotatedJob(val job: Job, val task: Task)

Functions

suspend fun close()

suspend fun kill()

suspend fun launch(task: Task)