File tree 1 file changed +4
-2
lines changed
1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ def get_state_if_exists(
23
23
tap_stream_id : str ,
24
24
state_partition_context : dict | None = None ,
25
25
key : str | None = None ,
26
- ) -> t .Any | None :
26
+ ) -> t .Any | None : # noqa: ANN401
27
27
"""Return the stream or partition state, creating a new one if it does not exist.
28
28
29
29
Args:
@@ -181,7 +181,9 @@ def write_starting_replication_value(
181
181
stream_or_partition_state [STARTING_MARKER ] = to_json_compatible (initial_value )
182
182
183
183
184
- def get_starting_replication_value (stream_or_partition_state : dict ) -> t .Any | None :
184
+ def get_starting_replication_value (
185
+ stream_or_partition_state : dict ,
186
+ ) -> t .Any | None : # noqa: ANN401
185
187
"""Retrieve initial replication marker value from state."""
186
188
if not stream_or_partition_state :
187
189
return None
You can’t perform that action at this time.
0 commit comments