destinations.dataset.utils

get_destination_clients

def get_destination_clients(
        schema: Schema,
        destination: AnyDestination = None,
        destination_dataset_name: str = None,
        multi_dataset_default_schema_name: str = None,
        staging: AnyDestination = None,
        staging_dataset_name: str = None
) -> Tuple[JobClientBase, JobClientBase]

[view_source]

Creates destination and/or staging job clients and binds them to schema and dataset names. Configuration in destination SPEC will be resolved.

if multi_dataset_default_schema_name is set, each schema gets own dataset name as dataset_name__{schema.name}, except the default schema that gets dataset_name