Skip to content

Commit 17ee2e6

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent 0bec3f7 commit 17ee2e6

File tree

1 file changed

+35
-15
lines changed

1 file changed

+35
-15
lines changed

airbyte_cdk/manifest_server/routers/manifest.py

Lines changed: 35 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -67,9 +67,13 @@ def safe_build_source(
6767
)
6868

6969

70-
@router.post("/test_read", operation_id="testRead", responses={
71-
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
72-
})
70+
@router.post(
71+
"/test_read",
72+
operation_id="testRead",
73+
responses={
74+
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
75+
},
76+
)
7377
def test_read(request: StreamTestReadRequest) -> StreamReadResponse:
7478
"""
7579
Test reading from a specific stream in the manifest.
@@ -120,9 +124,13 @@ def test_read(request: StreamTestReadRequest) -> StreamReadResponse:
120124
raise HTTPException(status_code=400, detail=error.message)
121125

122126

123-
@router.post("/check", operation_id="check", responses={
124-
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
125-
})
127+
@router.post(
128+
"/check",
129+
operation_id="check",
130+
responses={
131+
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
132+
},
133+
)
126134
def check(request: CheckRequest) -> CheckResponse:
127135
"""Check configuration against a manifest"""
128136
# Apply trace tags from context if provided
@@ -144,9 +152,13 @@ def check(request: CheckRequest) -> CheckResponse:
144152
raise HTTPException(status_code=400, detail=error.message)
145153

146154

147-
@router.post("/discover", operation_id="discover", responses={
148-
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
149-
})
155+
@router.post(
156+
"/discover",
157+
operation_id="discover",
158+
responses={
159+
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
160+
},
161+
)
150162
def discover(request: DiscoverRequest) -> DiscoverResponse:
151163
"""Discover streams from a manifest"""
152164
# Apply trace tags from context if provided
@@ -175,9 +187,13 @@ def discover(request: DiscoverRequest) -> DiscoverResponse:
175187
raise HTTPException(status_code=400, detail=error.message)
176188

177189

178-
@router.post("/resolve", operation_id="resolve", responses={
179-
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
180-
})
190+
@router.post(
191+
"/resolve",
192+
operation_id="resolve",
193+
responses={
194+
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
195+
},
196+
)
181197
def resolve(request: ResolveRequest) -> ManifestResponse:
182198
"""Resolve a manifest to its final configuration."""
183199
# Apply trace tags from context if provided
@@ -197,9 +213,13 @@ def resolve(request: ResolveRequest) -> ManifestResponse:
197213
raise HTTPException(status_code=400, detail=error.message)
198214

199215

200-
@router.post("/full_resolve", operation_id="fullResolve", responses={
201-
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
202-
})
216+
@router.post(
217+
"/full_resolve",
218+
operation_id="fullResolve",
219+
responses={
220+
400: {"description": "Bad Request - Error processing request", "model": ErrorResponse}
221+
},
222+
)
203223
def full_resolve(request: FullResolveRequest) -> ManifestResponse:
204224
"""
205225
Fully resolve a manifest, including dynamic streams.

0 commit comments

Comments
 (0)