From 74236398e332908597721f1a218cb54e1d353120 Mon Sep 17 00:00:00 2001 From: btkcodedev Date: Fri, 17 May 2024 23:17:23 +0530 Subject: [PATCH 1/3] make compatible with builder --- .../connectors/source-drift/metadata.yaml | 2 +- .../connectors/source-drift/pyproject.toml | 2 +- .../source-drift/source_drift/manifest.yaml | 892 ++++++++++-------- .../source-drift/source_drift/spec.yaml | 106 --- docs/integrations/sources/drift.md | 1 + 5 files changed, 518 insertions(+), 485 deletions(-) delete mode 100644 airbyte-integrations/connectors/source-drift/source_drift/spec.yaml diff --git a/airbyte-integrations/connectors/source-drift/metadata.yaml b/airbyte-integrations/connectors/source-drift/metadata.yaml index 6428e050d1943..7ffa2625f38c4 100644 --- a/airbyte-integrations/connectors/source-drift/metadata.yaml +++ b/airbyte-integrations/connectors/source-drift/metadata.yaml @@ -10,7 +10,7 @@ data: connectorSubtype: api connectorType: source definitionId: 445831eb-78db-4b1f-8f1f-0d96ad8739e2 - dockerImageTag: 0.3.4 + dockerImageTag: 0.3.5 dockerRepository: airbyte/source-drift documentationUrl: https://docs.airbyte.com/integrations/sources/drift githubIssueLabel: source-drift diff --git a/airbyte-integrations/connectors/source-drift/pyproject.toml b/airbyte-integrations/connectors/source-drift/pyproject.toml index 2541ef21a6611..c243cae1734d5 100644 --- a/airbyte-integrations/connectors/source-drift/pyproject.toml +++ b/airbyte-integrations/connectors/source-drift/pyproject.toml @@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",] build-backend = "poetry.core.masonry.api" [tool.poetry] -version = "0.3.4" +version = "0.3.5" name = "source-drift" description = "Source implementation for Drift." authors = [ "Airbyte ",] diff --git a/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml b/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml index e5fb763501a8d..0837b7eb86302 100644 --- a/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml +++ b/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml @@ -1,411 +1,549 @@ -version: "0.29.0" +version: 0.78.5 -definitions: - selector: - type: RecordSelector - extractor: - type: DpathExtractor - field_path: ["data"] +type: DeclarativeSource + +check: + type: CheckStream + stream_names: + - accounts - requester: +definitions: + streams: + accounts: + type: DeclarativeStream + name: accounts + primary_key: + - ownerId + retriever: + type: SimpleRetriever + requester: + $ref: '#/definitions/base_requester' + path: /accounts + http_method: GET + record_selector: + type: RecordSelector + extractor: + type: DpathExtractor + field_path: + - data + - accounts + paginator: + type: DefaultPaginator + page_token_option: + type: RequestPath + pagination_strategy: + type: CursorPagination + cursor_value: '{{ last_record[''next''] }}' + schema_loader: + type: InlineSchemaLoader + schema: + $ref: '#/schemas/accounts' + conversations: + type: DeclarativeStream + name: conversations + primary_key: + - id + retriever: + type: SimpleRetriever + requester: + $ref: '#/definitions/base_requester' + path: /conversations + http_method: GET + record_selector: + type: RecordSelector + extractor: + type: DpathExtractor + field_path: + - data + paginator: + type: DefaultPaginator + page_token_option: + type: RequestPath + pagination_strategy: + type: CursorPagination + cursor_value: '{{ last_record[''next''] }}' + schema_loader: + type: InlineSchemaLoader + schema: + $ref: '#/schemas/conversations' + users: + type: DeclarativeStream + name: users + primary_key: + - id + retriever: + type: SimpleRetriever + requester: + $ref: '#/definitions/base_requester' + path: /users + http_method: GET + record_selector: + type: RecordSelector + extractor: + type: DpathExtractor + field_path: + - data + schema_loader: + type: InlineSchemaLoader + schema: + $ref: '#/schemas/users' + contacts: + type: DeclarativeStream + name: contacts + primary_key: + - id + retriever: + type: SimpleRetriever + requester: + $ref: '#/definitions/base_requester' + path: /contacts + http_method: GET + request_parameters: + email: '{{ config[''email''] }}' + record_selector: + type: RecordSelector + extractor: + type: DpathExtractor + field_path: + - data + schema_loader: + type: InlineSchemaLoader + schema: + $ref: '#/schemas/contacts' + messages: + type: DeclarativeStream + name: messages + primary_key: + - id + retriever: + type: SimpleRetriever + requester: + $ref: '#/definitions/base_requester' + path: /conversations/{{ stream_partition.parent_id }}/messages + http_method: GET + record_selector: + type: RecordSelector + extractor: + type: DpathExtractor + field_path: + - data + - messages + paginator: + type: DefaultPaginator + page_token_option: + type: RequestPath + pagination_strategy: + type: CursorPagination + cursor_value: '{{ last_record[''next''] }}' + partition_router: + - type: SubstreamPartitionRouter + parent_stream_configs: + - type: ParentStreamConfig + parent_key: id + partition_field: parent_id + stream: + $ref: '#/definitions/streams/conversations' + schema_loader: + type: InlineSchemaLoader + schema: + $ref: '#/schemas/messages' + base_requester: type: HttpRequester - url_base: "https://driftapi.com" - http_method: "GET" + url_base: https://driftapi.com authenticator: type: BearerAuthenticator - api_token: "{{ config['credentials']['access_token'] }}" - - retriever: - type: SimpleRetriever - record_selector: - $ref: "#/definitions/selector" - paginator: - type: "NoPagination" - requester: - $ref: "#/definitions/requester" - - base_stream: - type: DeclarativeStream - retriever: - $ref: "#/definitions/retriever" + api_token: '{{ config[''credentials''][''access_token''] }}' - base_paginator: - type: "DefaultPaginator" - pagination_strategy: - type: "CursorPagination" - cursor_value: "{{ last_record['next'] }}" - page_token_option: - type: "RequestPath" - field_name: "page_token" - inject_into: "request_parameter" - - accounts_stream: - $ref: "#/definitions/base_stream" - retriever: - $ref: "#/definitions/retriever" - paginator: - $ref: "#/definitions/base_paginator" - record_selector: - type: RecordSelector - extractor: - type: DpathExtractor - field_path: ["data", "accounts"] - name: "accounts" - primary_key: "ownerId" - $parameters: - path: "/accounts" +streams: + - $ref: '#/definitions/streams/accounts' + - $ref: '#/definitions/streams/conversations' + - $ref: '#/definitions/streams/users' + - $ref: '#/definitions/streams/contacts' + - $ref: '#/definitions/streams/messages' - schema_loader: - type: InlineSchemaLoader - schema: - $schema: http://json-schema.org/draft-07/schema# +spec: + type: Spec + connection_specification: + type: object + $schema: http://json-schema.org/draft-07/schema# + required: [] + properties: + credentials: + type: object + title: Authorization Method + oneOf: + - type: object + title: OAuth2.0 + required: + - client_id + - client_secret + - access_token + - refresh_token + properties: + credentials: + type: string + const: oauth2.0 + order: 0 + client_id: + type: string + title: Client ID + description: The Client ID of your Drift developer application. + airbyte_secret: true + client_secret: + type: string + title: Client Secret + description: The Client Secret of your Drift developer application. + airbyte_secret: true + access_token: + type: string + title: Access Token + description: Access Token for making authenticated requests. + airbyte_secret: true + refresh_token: + type: string + title: Refresh Token + description: Refresh Token to renew the expired Access Token. + airbyte_secret: true + - type: object + title: Access Token + required: + - access_token + properties: + credentials: + type: string + const: access_token + order: 0 + access_token: + type: string + title: Access Token + description: >- + Drift Access Token. See the docs + for more information on how to generate this key. + airbyte_secret: true + order: 0 + email: + type: string + description: Email used as parameter for contacts stream + title: Email parameter for contacts stream + default: test@test.com + order: 1 + additionalProperties: true + advanced_auth: + auth_flow_type: oauth2.0 + predicate_key: + - credentials + - credentials + predicate_value: oauth2.0 + oauth_config_specification: + complete_oauth_output_specification: type: object properties: - ownerId: - description: The unique identifier of the account owner - type: integer - name: - description: The name of the account - type: string - domain: - description: The domain associated with the account + access_token: type: string - accountId: - description: The unique identifier for the account + path_in_connector_config: + - credentials + - access_token + refresh_token: type: string - customProperties: - description: Additional custom properties for the account - type: array - items: - description: A custom property for the account - type: object - properties: - label: - description: The label for a custom property - type: string - name: - description: The name of the custom property - type: string - value: - description: The value of the custom property - type: - description: The type of the custom property - type: string - deleted: - description: Indicates if the account has been deleted - type: boolean - createDateTime: - description: The date and time when the account was created - type: integer - updateDateTime: - description: The date and time when the account was last updated - type: integer - targeted: - description: Indicates if the account is a targeted account - type: boolean - conversations_stream: - $ref: "#/definitions/base_stream" - retriever: - $ref: "#/definitions/retriever" - paginator: - $ref: "#/definitions/base_paginator" - name: "conversations" - primary_key: "id" - $parameters: - path: "/conversations" - - schema_loader: - type: InlineSchemaLoader - schema: - $schema: http://json-schema.org/draft-07/schema# + path_in_connector_config: + - credentials + - refresh_token + complete_oauth_server_input_specification: type: object properties: - id: - description: The unique identifier of the conversation. - type: integer - participants: - description: List of participants involved in the conversation - type: array - items: - description: Details of the participants in the conversation. - type: integer - status: - description: The status of the conversation (e.g., open, closed, in progress). + client_id: type: string - enum: - - open - - closed - - pending - - bulk_sent - contactId: - description: - The unique identifier of the contact associated with the - conversation. - type: integer - inboxId: - description: - The unique identifier of the inbox where the conversation - belongs. - type: integer - createdAt: - description: The timestamp when the conversation was created. - type: integer - updatedAt: - description: The timestamp when the conversation was last updated. - type: integer - relatedPlaybookId: - description: - The unique identifier of the playbook related to the conversation, - if any. - type: - - "null" - - string - conversationTags: - description: Tags associated with the conversation - type: array - items: - description: Properties of each conversation tag - type: object - properties: - color: - type: string - description: HEX value - name: - description: The name of the tag associated with the conversation. - type: string - users_stream: - $ref: "#/definitions/base_stream" - name: "users" - primary_key: "id" - $parameters: - path: "/users" - - schema_loader: - type: InlineSchemaLoader - schema: - $schema: http://json-schema.org/draft-07/schema# + client_secret: + type: string + complete_oauth_server_output_specification: type: object properties: - id: - description: Unique identifier for the user. - type: integer - orgId: - description: Identifier for the organization the user belongs to. - type: integer - name: - description: User's full name. - type: string - alias: - description: User's alias used for identification. + client_id: type: string - email: - description: User's email address. + path_in_connector_config: + - credentials + - client_id + client_secret: type: string - phone: - description: User's phone number. - type: string - locale: - description: User's preferred language and region settings. - type: string - availability: - description: User's availability status. - type: string - role: - description: User's role or permission level. - type: string - timeZone: - description: User's preferred time zone. - type: string - avatarUrl: - description: URL for the user's avatar image. - type: string - verified: - description: Flag indicating if the user's account is verified. - type: boolean - bot: - description: Flag indicating if the user is a bot. - type: boolean - createdAt: - description: Timestamp when the user was created. - type: integer - updatedAt: - description: Timestamp when the user was last updated. - type: integer - contacts_stream: - $ref: "#/definitions/base_stream" - $parameters: - name: "contacts" - primary_key: "id" - path: "/contacts" - retriever: - $ref: "#/definitions/retriever" - requester: - $ref: "#/definitions/requester" - request_parameters: - email: "{{ config['email'] }}" + path_in_connector_config: + - credentials + - client_secret - schema_loader: - type: InlineSchemaLoader - schema: - $schema: http://json-schema.org/draft-07/schema# +metadata: + autoImportSchema: + accounts: false + conversations: false + users: false + contacts: false + messages: false + +schemas: + accounts: + type: object + $schema: http://json-schema.org/draft-07/schema# + properties: + accountId: + type: string + description: The unique identifier for the account + createDateTime: + type: integer + description: The date and time when the account was created + customProperties: + type: array + description: Additional custom properties for the account + items: + type: object + description: A custom property for the account + properties: + type: + type: string + description: The type of the custom property + label: + type: string + description: The label for a custom property + name: + type: string + description: The name of the custom property + value: + description: The value of the custom property + deleted: + type: boolean + description: Indicates if the account has been deleted + domain: + type: string + description: The domain associated with the account + name: + type: string + description: The name of the account + ownerId: + type: integer + description: The unique identifier of the account owner + targeted: + type: boolean + description: Indicates if the account is a targeted account + updateDateTime: + type: integer + description: The date and time when the account was last updated + additionalProperties: true + conversations: + type: object + $schema: http://json-schema.org/draft-07/schema# + properties: + contactId: + type: integer + description: The unique identifier of the contact associated with the conversation. + conversationTags: + type: array + description: Tags associated with the conversation + items: + type: object + description: Properties of each conversation tag + properties: + color: + type: string + description: HEX value + name: + type: string + description: The name of the tag associated with the conversation. + createdAt: + type: integer + description: The timestamp when the conversation was created. + id: + type: integer + description: The unique identifier of the conversation. + inboxId: + type: integer + description: The unique identifier of the inbox where the conversation belongs. + participants: + type: array + description: List of participants involved in the conversation + items: + type: integer + description: Details of the participants in the conversation. + relatedPlaybookId: + type: + - 'null' + - string + description: >- + The unique identifier of the playbook related to the conversation, if + any. + status: + type: string + description: The status of the conversation (e.g., open, closed, in progress). + enum: + - open + - closed + - pending + - bulk_sent + updatedAt: + type: integer + description: The timestamp when the conversation was last updated. + additionalProperties: true + users: + type: object + $schema: http://json-schema.org/draft-07/schema# + properties: + alias: + type: string + description: User's alias used for identification. + availability: + type: string + description: User's availability status. + avatarUrl: + type: string + description: URL for the user's avatar image. + bot: + type: boolean + description: Flag indicating if the user is a bot. + createdAt: + type: integer + description: Timestamp when the user was created. + email: + type: string + description: User's email address. + id: + type: integer + description: Unique identifier for the user. + locale: + type: string + description: User's preferred language and region settings. + name: + type: string + description: User's full name. + orgId: + type: integer + description: Identifier for the organization the user belongs to. + phone: + type: string + description: User's phone number. + role: + type: string + description: User's role or permission level. + timeZone: + type: string + description: User's preferred time zone. + updatedAt: + type: integer + description: Timestamp when the user was last updated. + verified: + type: boolean + description: Flag indicating if the user's account is verified. + additionalProperties: true + contacts: + type: object + $schema: http://json-schema.org/draft-07/schema# + properties: + attributes: type: object + description: Additional details of the contact properties: - id: - description: Unique identifier for the contact - type: integer + email: + type: string + description: Email address of the contact + events: + description: Events related to the contact name: + type: string description: Name of the contact + phone: type: string - attributes: - description: Additional details of the contact - type: object - properties: - name: - description: Name of the contact - type: string - email: - description: Email address of the contact - type: string - phone: - description: Phone number of the contact - type: string - tags: - description: Tags associated with the contact - type: array - items: - description: Tag name - type: string - events: - description: Events related to the contact - socialProfiles: - description: Social media profiles of the contact - createdAt: - description: Timestamp of when the contact was created - type: integer - messages_partition_router: - type: SubstreamPartitionRouter - parent_stream_configs: - - stream: "#/definitions/conversations_stream" - parent_key: "id" - partition_field: "parent_id" - - messages_stream: - $ref: "#/definitions/base_stream" - $parameters: - name: "messages" - primary_key: "id" - path: "/conversations/{{ stream_partition.parent_id }}/messages" - retriever: - $ref: "#/definitions/retriever" - paginator: - $ref: "#/definitions/base_paginator" - record_selector: - type: RecordSelector - extractor: - type: DpathExtractor - field_path: ["data", "messages"] - partition_router: - $ref: "#/definitions/messages_partition_router" - - schema_loader: - type: InlineSchemaLoader - schema: - $schema: http://json-schema.org/draft-07/schema# + description: Phone number of the contact + socialProfiles: + description: Social media profiles of the contact + tags: + type: array + description: Tags associated with the contact + items: + type: string + description: Tag name + createdAt: + type: integer + description: Timestamp of when the contact was created + id: + type: integer + description: Unique identifier for the contact + name: + type: string + description: Name of the contact + additionalProperties: true + messages: + type: object + $schema: http://json-schema.org/draft-07/schema# + properties: + type: + type: string + description: Type of message (e.g., text, image, file). + attributes: type: object + description: Additional attributes associated with the message. + author: + type: object + description: Details about the author of the message. properties: - id: - description: Unique identifier of the message. - type: integer - orgId: - description: - Unique identifier of the organization associated with the - message. - type: integer - body: - description: The main content/body of the message. - type: string - author: - description: Details about the author of the message. - type: object - properties: - type: - description: Type of the author (e.g., user, bot). - type: string - enum: - - contact - - user - id: - description: Unique identifier of the author. - type: integer - bot: - description: Boolean flag indicating if the author is a bot. - type: boolean type: - description: Type of message (e.g., text, image, file). type: string - conversationId: - description: - Unique identifier of the conversation associated with the - message. - type: integer - createdAt: - description: Timestamp indicating when the message was created. + description: Type of the author (e.g., user, bot). + enum: + - contact + - user + bot: + type: boolean + description: Boolean flag indicating if the author is a bot. + id: type: integer - buttons: - description: Action buttons associated with the message. - type: array - items: + description: Unique identifier of the author. + body: + type: string + description: The main content/body of the message. + buttons: + type: array + description: Action buttons associated with the message. + items: + type: object + properties: + type: + type: string + description: Type of button (e.g., call to action, link). + label: + type: string + description: Text label displayed on the button. + reaction: type: object + description: Reaction associated with the button click. properties: - label: - description: Text label displayed on the button. - type: string - value: - description: - Value associated with the button (e.g., URL, action - name). - type: string type: - description: Type of button (e.g., call to action, link). type: string - style: - description: Visual style of the button (e.g., primary, secondary). + description: Type of reaction triggered (e.g., message, action). + message: type: string - reaction: - description: Reaction associated with the button click. - type: object - properties: - type: - description: Type of reaction triggered (e.g., message, action). - type: string - message: - description: Message triggered by clicking the button. - type: string - context: - description: Contextual information related to the message. - type: object - properties: - ip: - description: IP address associated with the message. - type: string - userAgent: - description: User agent information of the client device. - type: string - attributes: - description: Additional attributes associated with the message. - type: object -streams: - - "#/definitions/accounts_stream" - - "#/definitions/conversations_stream" - - "#/definitions/users_stream" - - "#/definitions/contacts_stream" - - "#/definitions/messages_stream" - -check: - type: CheckStream - stream_names: - - "accounts" - - "conversations" - - "users" - - "contacts" - - "messages" + description: Message triggered by clicking the button. + style: + type: string + description: Visual style of the button (e.g., primary, secondary). + value: + type: string + description: Value associated with the button (e.g., URL, action name). + context: + type: object + description: Contextual information related to the message. + properties: + ip: + type: string + description: IP address associated with the message. + userAgent: + type: string + description: User agent information of the client device. + conversationId: + type: integer + description: Unique identifier of the conversation associated with the message. + createdAt: + type: integer + description: Timestamp indicating when the message was created. + id: + type: integer + description: Unique identifier of the message. + orgId: + type: integer + description: Unique identifier of the organization associated with the message. + additionalProperties: true diff --git a/airbyte-integrations/connectors/source-drift/source_drift/spec.yaml b/airbyte-integrations/connectors/source-drift/source_drift/spec.yaml deleted file mode 100644 index bbbc429a5ac36..0000000000000 --- a/airbyte-integrations/connectors/source-drift/source_drift/spec.yaml +++ /dev/null @@ -1,106 +0,0 @@ -documentationUrl: https://docs.airbyte.com/integrations/sources/drift -connectionSpecification: - $schema: http://json-schema.org/draft-07/schema# - title: Drift Spec - type: object - required: [] - additionalProperties: true - properties: - email: - type: string - description: Email used as parameter for contacts stream - title: Email parameter for contacts stream - default: "test@test.com" - credentials: - title: Authorization Method - type: object - oneOf: - - type: object - title: OAuth2.0 - required: - - client_id - - client_secret - - access_token - - refresh_token - properties: - credentials: - type: string - const: oauth2.0 - order: 0 - client_id: - type: string - title: Client ID - description: The Client ID of your Drift developer application. - airbyte_secret: true - client_secret: - type: string - title: Client Secret - description: The Client Secret of your Drift developer application. - airbyte_secret: true - access_token: - type: string - title: Access Token - description: Access Token for making authenticated requests. - airbyte_secret: true - refresh_token: - type: string - title: Refresh Token - description: Refresh Token to renew the expired Access Token. - default: "" - airbyte_secret: true - - title: Access Token - type: object - required: - - access_token - properties: - credentials: - type: string - const: access_token - order: 0 - access_token: - type: string - title: Access Token - description: - Drift Access Token. See the docs - for more information on how to generate this key. - airbyte_secret: true -advanced_auth: - auth_flow_type: oauth2.0 - predicate_key: - - credentials - - credentials - predicate_value: oauth2.0 - oauth_config_specification: - complete_oauth_output_specification: - type: object - properties: - access_token: - type: string - path_in_connector_config: - - credentials - - access_token - refresh_token: - type: string - path_in_connector_config: - - credentials - - refresh_token - complete_oauth_server_input_specification: - type: object - properties: - client_id: - type: string - client_secret: - type: string - complete_oauth_server_output_specification: - type: object - properties: - client_id: - type: string - path_in_connector_config: - - credentials - - client_id - client_secret: - type: string - path_in_connector_config: - - credentials - - client_secret diff --git a/docs/integrations/sources/drift.md b/docs/integrations/sources/drift.md index 6ce8277721eac..2094ea3ae79de 100644 --- a/docs/integrations/sources/drift.md +++ b/docs/integrations/sources/drift.md @@ -53,6 +53,7 @@ The Drift connector should not run into Drift API limitations under normal usage | Version | Date | Pull Request | Subject | | :------ | :--------- | :------------------------------------------------------- | :------------------------------------------------------------------------------ | +| 0.3.5 | 2024-05-20 | [00000](https://github.com/airbytehq/airbyte/pull/00000) | Make compatability with builder | | 0.3.4 | 2024-05-03 | [37592](https://github.com/airbytehq/airbyte/pull/37592) | Change `last_records` to `last_record` | | 0.3.3 | 2024-04-19 | [37153](https://github.com/airbytehq/airbyte/pull/37153) | Upgrade to CDK 0.80.0 and manage dependencies with Poetry. | | 0.3.2 | 2024-04-15 | [37153](https://github.com/airbytehq/airbyte/pull/37153) | Base image migration: remove Dockerfile and use the python-connector-base image | From 648bfc371782334c32f6e1bdeee156802c3a1d17 Mon Sep 17 00:00:00 2001 From: btkcodedev Date: Fri, 17 May 2024 23:18:35 +0530 Subject: [PATCH 2/3] update docs --- docs/integrations/sources/drift.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/integrations/sources/drift.md b/docs/integrations/sources/drift.md index 2094ea3ae79de..09f65816b1af6 100644 --- a/docs/integrations/sources/drift.md +++ b/docs/integrations/sources/drift.md @@ -53,7 +53,7 @@ The Drift connector should not run into Drift API limitations under normal usage | Version | Date | Pull Request | Subject | | :------ | :--------- | :------------------------------------------------------- | :------------------------------------------------------------------------------ | -| 0.3.5 | 2024-05-20 | [00000](https://github.com/airbytehq/airbyte/pull/00000) | Make compatability with builder | +| 0.3.5 | 2024-05-20 | [38321](https://github.com/airbytehq/airbyte/pull/38321) | Make compatability with builder | | 0.3.4 | 2024-05-03 | [37592](https://github.com/airbytehq/airbyte/pull/37592) | Change `last_records` to `last_record` | | 0.3.3 | 2024-04-19 | [37153](https://github.com/airbytehq/airbyte/pull/37153) | Upgrade to CDK 0.80.0 and manage dependencies with Poetry. | | 0.3.2 | 2024-04-15 | [37153](https://github.com/airbytehq/airbyte/pull/37153) | Base image migration: remove Dockerfile and use the python-connector-base image | From 9cf66c825d40f56c75b1e4360e0e69460922ad43 Mon Sep 17 00:00:00 2001 From: btkcodedev Date: Fri, 17 May 2024 23:34:54 +0530 Subject: [PATCH 3/3] chore: format --- .../source-drift/source_drift/manifest.yaml | 44 +++++++++---------- 1 file changed, 22 insertions(+), 22 deletions(-) diff --git a/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml b/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml index 0837b7eb86302..50cfdba55d4db 100644 --- a/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml +++ b/airbyte-integrations/connectors/source-drift/source_drift/manifest.yaml @@ -17,7 +17,7 @@ definitions: retriever: type: SimpleRetriever requester: - $ref: '#/definitions/base_requester' + $ref: "#/definitions/base_requester" path: /accounts http_method: GET record_selector: @@ -33,11 +33,11 @@ definitions: type: RequestPath pagination_strategy: type: CursorPagination - cursor_value: '{{ last_record[''next''] }}' + cursor_value: "{{ last_record['next'] }}" schema_loader: type: InlineSchemaLoader schema: - $ref: '#/schemas/accounts' + $ref: "#/schemas/accounts" conversations: type: DeclarativeStream name: conversations @@ -46,7 +46,7 @@ definitions: retriever: type: SimpleRetriever requester: - $ref: '#/definitions/base_requester' + $ref: "#/definitions/base_requester" path: /conversations http_method: GET record_selector: @@ -61,11 +61,11 @@ definitions: type: RequestPath pagination_strategy: type: CursorPagination - cursor_value: '{{ last_record[''next''] }}' + cursor_value: "{{ last_record['next'] }}" schema_loader: type: InlineSchemaLoader schema: - $ref: '#/schemas/conversations' + $ref: "#/schemas/conversations" users: type: DeclarativeStream name: users @@ -74,7 +74,7 @@ definitions: retriever: type: SimpleRetriever requester: - $ref: '#/definitions/base_requester' + $ref: "#/definitions/base_requester" path: /users http_method: GET record_selector: @@ -86,7 +86,7 @@ definitions: schema_loader: type: InlineSchemaLoader schema: - $ref: '#/schemas/users' + $ref: "#/schemas/users" contacts: type: DeclarativeStream name: contacts @@ -95,11 +95,11 @@ definitions: retriever: type: SimpleRetriever requester: - $ref: '#/definitions/base_requester' + $ref: "#/definitions/base_requester" path: /contacts http_method: GET request_parameters: - email: '{{ config[''email''] }}' + email: "{{ config['email'] }}" record_selector: type: RecordSelector extractor: @@ -109,7 +109,7 @@ definitions: schema_loader: type: InlineSchemaLoader schema: - $ref: '#/schemas/contacts' + $ref: "#/schemas/contacts" messages: type: DeclarativeStream name: messages @@ -118,7 +118,7 @@ definitions: retriever: type: SimpleRetriever requester: - $ref: '#/definitions/base_requester' + $ref: "#/definitions/base_requester" path: /conversations/{{ stream_partition.parent_id }}/messages http_method: GET record_selector: @@ -134,7 +134,7 @@ definitions: type: RequestPath pagination_strategy: type: CursorPagination - cursor_value: '{{ last_record[''next''] }}' + cursor_value: "{{ last_record['next'] }}" partition_router: - type: SubstreamPartitionRouter parent_stream_configs: @@ -142,24 +142,24 @@ definitions: parent_key: id partition_field: parent_id stream: - $ref: '#/definitions/streams/conversations' + $ref: "#/definitions/streams/conversations" schema_loader: type: InlineSchemaLoader schema: - $ref: '#/schemas/messages' + $ref: "#/schemas/messages" base_requester: type: HttpRequester url_base: https://driftapi.com authenticator: type: BearerAuthenticator - api_token: '{{ config[''credentials''][''access_token''] }}' + api_token: "{{ config['credentials']['access_token'] }}" streams: - - $ref: '#/definitions/streams/accounts' - - $ref: '#/definitions/streams/conversations' - - $ref: '#/definitions/streams/users' - - $ref: '#/definitions/streams/contacts' - - $ref: '#/definitions/streams/messages' + - $ref: "#/definitions/streams/accounts" + - $ref: "#/definitions/streams/conversations" + - $ref: "#/definitions/streams/users" + - $ref: "#/definitions/streams/contacts" + - $ref: "#/definitions/streams/messages" spec: type: Spec @@ -363,7 +363,7 @@ schemas: description: Details of the participants in the conversation. relatedPlaybookId: type: - - 'null' + - "null" - string description: >- The unique identifier of the playbook related to the conversation, if