File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
unit_tests/sources/declarative Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change 4
4
5
5
from typing import Any , Mapping
6
6
7
- from airbyte_cdk .sources .declarative .declarative_stream import DeclarativeStream
8
7
from airbyte_cdk .sources .declarative .interpolation .interpolated_string import InterpolatedString
9
8
from airbyte_cdk .sources .declarative .migrations .state_migration import StateMigration
9
+ from airbyte_cdk .sources .declarative .models .declarative_component_schema import (
10
+ DeclarativeStream as DeclarativeStreamModel ,
11
+ )
10
12
from airbyte_cdk .sources .types import Config
11
13
12
14
13
15
class CustomStateMigration (StateMigration ):
14
- declarative_stream : DeclarativeStream
16
+ declarative_stream : DeclarativeStreamModel
15
17
config : Config
16
18
17
- def __init__ (self , declarative_stream : DeclarativeStream , config : Config ):
19
+ def __init__ (self , declarative_stream : DeclarativeStreamModel , config : Config ):
18
20
self ._config = config
19
21
self .declarative_stream = declarative_stream
20
22
self ._cursor = declarative_stream .incremental_sync
You can’t perform that action at this time.
0 commit comments