Skip to content

Commit b183f80

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

2 files changed

Lines changed: 19 additions & 19 deletions

File tree

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.
@@ -4172,6 +4157,21 @@ definitions:
41724157
title: Action
41734158
description: The action to apply to streams in this group.
41744159
"$ref": "#/definitions/BlockSimultaneousSyncsAction"
4160+
BlockSimultaneousSyncsAction:
4161+
title: Block Simultaneous Syncs Action
4162+
description: >
4163+
Action that prevents streams in the same group from being read concurrently.
4164+
When applied to a stream group, streams with this action will be deferred if
4165+
another stream in the same group is currently active.
4166+
This is useful for APIs that don't allow concurrent access to the same
4167+
endpoint or session. Only applies to ConcurrentDeclarativeSource.
4168+
type: object
4169+
required:
4170+
- type
4171+
properties:
4172+
type:
4173+
type: string
4174+
enum: [BlockSimultaneousSyncsAction]
41754175
SubstreamPartitionRouter:
41764176
title: Substream Partition Router
41774177
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(
@@ -3067,6 +3063,10 @@ class AsyncRetriever(BaseModel):
30673063
parameters: Optional[Dict[str, Any]] = Field(None, alias="$parameters")
30683064

30693065

3066+
class BlockSimultaneousSyncsAction(BaseModel):
3067+
type: Literal["BlockSimultaneousSyncsAction"]
3068+
3069+
30703070
class StreamGroup(BaseModel):
30713071
streams: List[str] = Field(
30723072
...,

0 commit comments

Comments
 (0)