Skip to content

Commit fa6bdbe

Browse files
style: move BlockSimultaneousSyncsAction next to StreamGroup for easier reading
Co-Authored-By: unknown <>
1 parent acd7a18 commit fa6bdbe

File tree

2 files changed

+19
-19
lines changed

2 files changed

+19
-19
lines changed

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -275,21 +275,6 @@ definitions:
275275
$parameters:
276276
type: object
277277
additionalProperties: true
278-
BlockSimultaneousSyncsAction:
279-
title: Block Simultaneous Syncs Action
280-
description: >
281-
Action that prevents streams in the same group from being read concurrently.
282-
When applied to a stream group, streams with this action will be deferred if
283-
another stream in the same group is currently active.
284-
This is useful for APIs that don't allow concurrent access to the same
285-
endpoint or session. Only applies to ConcurrentDeclarativeSource.
286-
type: object
287-
required:
288-
- type
289-
properties:
290-
type:
291-
type: string
292-
enum: [BlockSimultaneousSyncsAction]
293278
SelectiveAuthenticator:
294279
title: Selective Authenticator
295280
description: Authenticator that selects concrete authenticator based on config property.
@@ -4151,6 +4136,21 @@ definitions:
41514136
title: Action
41524137
description: The action to apply to streams in this group.
41534138
"$ref": "#/definitions/BlockSimultaneousSyncsAction"
4139+
BlockSimultaneousSyncsAction:
4140+
title: Block Simultaneous Syncs Action
4141+
description: >
4142+
Action that prevents streams in the same group from being read concurrently.
4143+
When applied to a stream group, streams with this action will be deferred if
4144+
another stream in the same group is currently active.
4145+
This is useful for APIs that don't allow concurrent access to the same
4146+
endpoint or session. Only applies to ConcurrentDeclarativeSource.
4147+
type: object
4148+
required:
4149+
- type
4150+
properties:
4151+
type:
4152+
type: string
4153+
enum: [BlockSimultaneousSyncsAction]
41544154
SubstreamPartitionRouter:
41554155
title: Substream Partition Router
41564156
description: Partition router that is used to retrieve records that have been partitioned according to records from the specified parent streams. An example of a parent stream is automobile brands and the substream would be the various car models associated with each branch.

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -46,10 +46,6 @@ class BearerAuthenticator(BaseModel):
4646
parameters: Optional[Dict[str, Any]] = Field(None, alias="$parameters")
4747

4848

49-
class BlockSimultaneousSyncsAction(BaseModel):
50-
type: Literal["BlockSimultaneousSyncsAction"]
51-
52-
5349
class DynamicStreamCheckConfig(BaseModel):
5450
type: Literal["DynamicStreamCheckConfig"]
5551
dynamic_stream_name: str = Field(
@@ -3055,6 +3051,10 @@ class AsyncRetriever(BaseModel):
30553051
parameters: Optional[Dict[str, Any]] = Field(None, alias="$parameters")
30563052

30573053

3054+
class BlockSimultaneousSyncsAction(BaseModel):
3055+
type: Literal["BlockSimultaneousSyncsAction"]
3056+
3057+
30583058
class StreamGroup(BaseModel):
30593059
streams: List[str] = Field(
30603060
...,

0 commit comments

Comments
 (0)