Merge pull request #4045 from open-metadata/issue-4042

Fix #4042: Ingestion: Sample data ingestion is failing
This commit is contained in:
Sriharsha Chintalapani 2022-04-11 17:30:14 -07:00 committed by GitHub
commit d49defcd77
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
43 changed files with 461 additions and 455 deletions

View File

@ -19,6 +19,16 @@
"additionalProperties": {
"type": "string"
}
},
"supportsMetadataExtraction": {
"description": "Supports Metadata Extraction.",
"type": "boolean",
"default": "true"
},
"supportsUsageExtraction": {
"description": "Supports Usage Extraction.",
"type": "boolean",
"default": "true"
}
}
}

View File

@ -38,7 +38,7 @@
"type": "string"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -37,7 +37,7 @@
"type": "string"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -51,7 +51,7 @@
"default": null
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -34,7 +34,7 @@
"type": "string"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -49,7 +49,7 @@
"type": "object"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -53,7 +53,7 @@
"type": "string"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -60,13 +60,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -53,13 +53,13 @@
"default": "{ODBC Driver 17 for SQL Server}"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -73,16 +73,16 @@
"default": "_PARTITIONTIME"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
},
"supportsUsageExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsUsageExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsUsageExtraction"
}
},
"additionalProperties": false

View File

@ -52,16 +52,16 @@
"type": "integer"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
},
"supportsUsageExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsUsageExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsUsageExtraction"
}
},
"additionalProperties": false

View File

@ -52,13 +52,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -32,13 +32,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -50,13 +50,13 @@
"default": "DynamoDB"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -58,13 +58,13 @@
"default": "Glue"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -52,13 +52,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -52,13 +52,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -53,13 +53,13 @@
"default": null
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -52,13 +52,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -52,13 +52,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -9,14 +9,14 @@
"sampledataType": {
"description": "Service type.",
"type": "string",
"enum": ["BigQuery"],
"default": "BigQuery"
"enum": ["SampleData"],
"default": "SampleData"
},
"sampledataScheme": {
"description": "SQLAlchemy driver scheme options.",
"type": "string",
"enum": ["bigquery"],
"default": "bigquery"
"enum": ["sampledata"],
"default": "sampledata"
}
},
"properties": {
@ -30,19 +30,16 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportedPipelineTypes": {
"description": "Supported Metadata Extraction Pipelines.",
"type": "string",
"items": {
"type": "string",
"enum": ["Metadata", "Usage"]
},
"default": ["Metadata", "Usage"]
"supportsMetadataExtraction": {
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
},
"supportsUsageExtraction": {
"$ref": "../connectionBasicType.json#/definitions/supportsUsageExtraction"
}
},
"additionalProperties": false

View File

@ -48,13 +48,13 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -60,16 +60,16 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
},
"supportsUsageExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsUsageExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsUsageExtraction"
}
},
"additionalProperties": false

View File

@ -53,13 +53,13 @@
"default": ":memory:"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -52,10 +52,10 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"proxies": {
"description": "Proxies for the connection to Trino data source",
@ -66,7 +66,7 @@
"type": "object"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -48,16 +48,16 @@
"type": "string"
},
"connectionOptions": {
"$ref": "connectionBasicType.json#/definitions/connectionOptions"
"$ref": "../connectionBasicType.json#/definitions/connectionOptions"
},
"connectionArguments": {
"$ref": "connectionBasicType.json#/definitions/connectionArguments"
"$ref": "../connectionBasicType.json#/definitions/connectionArguments"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
},
"supportsUsageExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsUsageExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsUsageExtraction"
}
},
"additionalProperties": false

View File

@ -31,7 +31,7 @@
"default": "http://localhost:8081"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -20,7 +20,7 @@
"default": "Pulsar"
},
"supportsMetadataExtraction": {
"$ref": "../serviceConnection.json#/definitions/supportsMetadataExtraction"
"$ref": "../connectionBasicType.json#/definitions/supportsMetadataExtraction"
}
},
"additionalProperties": false

View File

@ -18,16 +18,6 @@
"$ref": "../messagingService.json#/definitions/messagingConnection"
}
]
},
"supportsMetadataExtraction": {
"description": "Supports Metadata Extraction.",
"type": "boolean",
"default": "true"
},
"supportsUsageExtraction": {
"description": "Supports Usage Extraction.",
"type": "boolean",
"default": "true"
}
},
"properties": {

View File

@ -32,7 +32,8 @@
"SingleStore",
"SQLite",
"DeltaLake",
"Salesforce"
"Salesforce",
"SampleData"
],
"javaEnums": [
{
@ -106,6 +107,9 @@
},
{
"name": "Salesforce"
},
{
"name": "SampleData"
}
]
},

View File

@ -7,5 +7,5 @@ Provides metadata version information.
from incremental import Version
__version__ = Version("metadata", 0, 9, 0, dev=25)
__version__ = Version("metadata", 0, 9, 0, dev=27)
__all__ = ["__version__"]

View File

@ -4,6 +4,6 @@
"description": "This **mock** database contains schemas related to shopify sales and orders with related dimension tables.",
"service": {
"id": "b946d870-03b2-4d33-a075-13665a7a76b9",
"type": "BIGQUERY"
"type": "SAMPLEDATA"
}
}

View File

@ -1,6 +1,6 @@
[
{
"table": "bigquery_gcp.ecommerce_db.shopify.dim_staff",
"table": "sample_data.ecommerce_db.shopify.dim_staff",
"tableTests": [
{
"description": "Rows should always be 100 because of something",

File diff suppressed because it is too large Load Diff

View File

@ -1,25 +1,25 @@
[{
"from": { "fqn":"bigquery_gcp.ecommerce_db.shopify.raw_customer", "type": "table"},
"from": { "fqn":"sample_data.ecommerce_db.shopify.raw_customer", "type": "table"},
"to": { "fqn":"sample_airflow.dim_address_etl", "type": "pipeline"}
},
{
"from": {"fqn":"sample_airflow.dim_address_etl", "type": "pipeline"},
"to": {"fqn":"bigquery_gcp.ecommerce_db.shopify.dim_address", "type": "table"}
"to": {"fqn":"sample_data.ecommerce_db.shopify.dim_address", "type": "table"}
},
{
"from": {"fqn":"bigquery_gcp.ecommerce_db.shopify.raw_order", "type": "table"},
"from": {"fqn":"sample_data.ecommerce_db.shopify.raw_order", "type": "table"},
"to": {"fqn":"sample_airflow.dim_product_etl", "type": "pipeline"}
},
{
"from": {"fqn":"bigquery_gcp.ecommerce_db.shopify.raw_customer", "type": "table"},
"from": {"fqn":"sample_data.ecommerce_db.shopify.raw_customer", "type": "table"},
"to": {"fqn":"sample_airflow.dim_product_etl", "type": "pipeline"}
},
{
"from": {"fqn":"sample_airflow.dim_product_etl", "type": "pipeline"},
"to": {"fqn":"bigquery_gcp.ecommerce_db.shopify.\"dim.product\"", "type": "table"}
"to": {"fqn":"sample_data.ecommerce_db.shopify.\"dim.product\"", "type": "table"}
},
{
"from": {"fqn": "sample_airflow.dim_product_etl", "type": "pipeline"},
"to": {"fqn":"bigquery_gcp.ecommerce_db.shopify.\"dim.product.variant\"", "type": "table"}
"to": {"fqn":"sample_data.ecommerce_db.shopify.\"dim.product.variant\"", "type": "table"}
}
]

View File

@ -1,10 +1,11 @@
{
"source": {
"type": "sample-data",
"serviceName": "bigquery_gcp",
"type": "sample_data",
"serviceName": "sample_data",
"serviceConnection": {
"config": {
"type": "BigQuery"
"type": "SampleData",
"sampleDataFolder": "./examples/sample_data"
}
},
"sourceConfig": {}

View File

@ -343,7 +343,11 @@ class SampleDataSource(Source[Entity]):
)
)
self.pipeline_status = json.load(
open(self.config.sample_data_folder + "/pipelines/pipelineStatus.json", "r")
open(
self.service_connection.sampleDataFolder
+ "/pipelines/pipelineStatus.json",
"r",
)
)
@classmethod
@ -353,7 +357,7 @@ class SampleDataSource(Source[Entity]):
connection: SampleDataConnection = config.serviceConnection.__root__.config
if not isinstance(connection, SampleDataConnection):
raise InvalidSourceException(
f"Expected MssqlConnection, but got {connection}"
f"Expected SampleDataConnection, but got {connection}"
)
return cls(config, metadata_config)