File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
Expand file tree Collapse file tree 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(
2323 tap_stream_id : str ,
2424 state_partition_context : dict | None = None ,
2525 key : str | None = None ,
26- ) -> t .Any | None :
26+ ) -> t .Any | None : # noqa: ANN401
2727 """Return the stream or partition state, creating a new one if it does not exist.
2828
2929 Args:
@@ -181,7 +181,9 @@ def write_starting_replication_value(
181181 stream_or_partition_state [STARTING_MARKER ] = to_json_compatible (initial_value )
182182
183183
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
185187 """Retrieve initial replication marker value from state."""
186188 if not stream_or_partition_state :
187189 return None
You can’t perform that action at this time.
0 commit comments