Skip to content

Commit d278745

Browse files
brianjlaiakashkulk
authored andcommitted
Add the /manifest_template endpoint to return a string representation of the manifest template (#19367)
* return a string representation of the manifest template * get rid of extra template * add a comment
1 parent 5395bf9 commit d278745

File tree

1 file changed

+50
-1
lines changed

1 file changed

+50
-1
lines changed

airbyte-connector-builder-server/connector_builder/impl/default_api.py

Lines changed: 50 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,56 @@
1313

1414
class DefaultApiImpl(DefaultApi):
1515
async def get_manifest_template(self) -> str:
16-
return "Hello World"
16+
return """version: "0.1.0"
17+
18+
definitions:
19+
selector:
20+
extractor:
21+
field_pointer: []
22+
requester:
23+
url_base: "https://example.com"
24+
http_method: "GET"
25+
authenticator:
26+
type: BearerAuthenticator
27+
api_token: "{{ config['api_key'] }}"
28+
retriever:
29+
record_selector:
30+
$ref: "*ref(definitions.selector)"
31+
paginator:
32+
type: NoPagination
33+
requester:
34+
$ref: "*ref(definitions.requester)"
35+
base_stream:
36+
retriever:
37+
$ref: "*ref(definitions.retriever)"
38+
customers_stream:
39+
$ref: "*ref(definitions.base_stream)"
40+
$options:
41+
name: "customers"
42+
primary_key: "id"
43+
path: "/example"
44+
45+
streams:
46+
- "*ref(definitions.customers_stream)"
47+
48+
check:
49+
stream_names:
50+
- "customers"
51+
52+
spec:
53+
documentation_url: https://docsurl.com
54+
connection_specification:
55+
title: Source Name Spec # 'TODO: Replace this with the name of your source.'
56+
type: object
57+
required:
58+
- api_key
59+
additionalProperties: true
60+
properties:
61+
# 'TODO: This schema defines the configuration required for the source. This usually involves metadata such as database and/or authentication information.':
62+
api_key:
63+
type: string
64+
description: API Key
65+
"""
1766

1867
async def list_streams(self, streams_list_request_body: StreamsListRequestBody = Body(None, description="")) -> StreamsListRead:
1968
raise Exception("not yet implemented")

0 commit comments

Comments
 (0)