From f4127166b58a1ba759f82dad4d0108d737c4cf32 Mon Sep 17 00:00:00 2001 From: Alexander Marquardt Date: Wed, 13 Jul 2022 21:15:19 +0200 Subject: [PATCH] Added _id and _cid to the schema (catalog) (#14647) Thanks for approving! --- .../connectors/source-webflow/source_webflow/source.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/airbyte-integrations/connectors/source-webflow/source_webflow/source.py b/airbyte-integrations/connectors/source-webflow/source_webflow/source.py index 2dad6eb5671f..17c2587095d5 100644 --- a/airbyte-integrations/connectors/source-webflow/source_webflow/source.py +++ b/airbyte-integrations/connectors/source-webflow/source_webflow/source.py @@ -238,6 +238,14 @@ def get_json_schema(self) -> Mapping[str, Any]: for schema_property in schema_records: json_schema.update(schema_property) + # Manually add in _cid and _id, which are not included in the list of fields sent back from Webflow, + # but which are necessary for joining data in the database + extra_fields = { + "_id": {"type": ["null", "string"]}, + "_cid": {"type": ["null", "string"]}, + } + json_schema.update(extra_fields) + return { "$schema": "http://json-schema.org/draft-07/schema#", "additionalProperties": True,