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]
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