def _get_offline_details()

in pipeline_utils.py [0:0]


def _get_offline_details(fg_name, sagemaker_client, s3_uri=None):
    _data_catalog_config = describe_feature_group(fg_name)['OfflineStoreConfig']['DataCatalogConfig']
    _table = _data_catalog_config['TableName']
    _database = _data_catalog_config['Database']

    if s3_uri is None:
        s3_uri = f's3://{sagemaker.Session().default_bucket()}/offline-store'
    _tmp_uri = f'{s3_uri}/query_results/'
    print(_tmp_uri)
    return _table, _database, _tmp_uri