diff --git a/src/plugins/operators/validate_manifest_schema.py b/src/plugins/operators/validate_manifest_schema.py index ca5e7488e6caccb1681d79a227cb3d8d92316b3a..e518ffe79cfd1c5d7661a550772fce0f171c06a1 100644 --- a/src/plugins/operators/validate_manifest_schema.py +++ b/src/plugins/operators/validate_manifest_schema.py @@ -41,7 +41,7 @@ class ValidateManifestSchemaOperator(BaseOperator, ReceivingContextMixin): """Init base operator and obtain base urls from Airflow Variables.""" super().__init__(*args, **kwargs) self.previous_task_id = previous_task_id - self.schema_service_url = Variable.get('schema_service_url') + self.schema_service_url = Variable.get('core.service.schema.url') def execute(self, context: dict): """Execute manifest validation then process it.