Skip to content

Commit f52bc2e

Browse files
authored
feat(dynamic-streams): Add StateDelegatingStream to DynamicDeclarativeStream (#560)
1 parent ce44cc5 commit f52bc2e

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4140,7 +4140,9 @@ definitions:
41404140
stream_template:
41414141
title: Stream Template
41424142
description: Reference to the stream template.
4143-
"$ref": "#/definitions/DeclarativeStream"
4143+
anyOf:
4144+
- "$ref": "#/definitions/DeclarativeStream"
4145+
- "$ref": "#/definitions/StateDelegatingStream"
41444146
components_resolver:
41454147
title: Components Resolver
41464148
description: Component resolve and populates stream templates with components values.

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2906,7 +2906,7 @@ class DynamicDeclarativeStream(BaseModel):
29062906
name: Optional[str] = Field(
29072907
"", description="The dynamic stream name.", example=["Tables"], title="Name"
29082908
)
2909-
stream_template: DeclarativeStream = Field(
2909+
stream_template: Union[DeclarativeStream, StateDelegatingStream] = Field(
29102910
..., description="Reference to the stream template.", title="Stream Template"
29112911
)
29122912
components_resolver: Union[HttpComponentsResolver, ConfigComponentsResolver] = Field(

0 commit comments

Comments
 (0)