Skip to content

Commit

Permalink
Auto-fix lint and format issues
Browse files Browse the repository at this point in the history
  • Loading branch information
octavia-squidington-iii committed Jan 24, 2025
1 parent 516f844 commit f5c61c0
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -933,7 +933,11 @@ def create_concurrent_cursor_from_datetime_based_cursor(
runtime_lookback_window: Optional[datetime.timedelta] = None,
**kwargs: Any,
) -> ConcurrentCursor:
stream_state = self._connector_state_manager.get_stream_state(stream_name, stream_namespace) if "stream_state" not in kwargs else kwargs["stream_state"]
stream_state = (
self._connector_state_manager.get_stream_state(stream_name, stream_namespace)
if "stream_state" not in kwargs
else kwargs["stream_state"]
)

component_type = component_definition.get("type")
if component_definition.get("type") != model_type.__name__:
Expand Down

0 comments on commit f5c61c0

Please sign in to comment.