diff --git a/ingestion/src/metadata/ingestion/source/sample_usage.py b/ingestion/src/metadata/ingestion/source/sample_usage.py index 39e2a54b5bf..805758ab0a9 100644 --- a/ingestion/src/metadata/ingestion/source/sample_usage.py +++ b/ingestion/src/metadata/ingestion/source/sample_usage.py @@ -30,9 +30,7 @@ class SampleUsageSource(Source): self.query_log_csv = config.sample_data_folder + "/datasets/query_log" with open(self.query_log_csv, "r") as fin: self.query_logs = [dict(i) for i in csv.DictReader(fin)] - self.service = get_database_service_or_create( - self.service_json, metadata_config - ) + self.service = get_database_service_or_create(self.config, metadata_config) @classmethod def create(cls, config_dict, metadata_config_dict, ctx):