Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion airbyte/_connector_base.py
Original file line number Diff line number Diff line change
Expand Up @@ -486,7 +486,7 @@ def _execute(
self._peek_airbyte_message(message)
yield message

except Exception:
except Exception: # noqa: PERF203
# This is likely a log message, so log it as INFO.
self._print_info_message(line)

Expand Down
2 changes: 1 addition & 1 deletion airbyte/_message_iterators.py
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ def generator() -> Generator[AirbyteMessage, None, None]:
try:
# Let Pydantic handle the JSON decoding from the raw string
yield AirbyteMessage.model_validate_json(line)
except pydantic.ValidationError:
except pydantic.ValidationError: # noqa: PERF203
# Handle JSON decoding errors (optional)
raise ValueError(f"Invalid JSON format in input string: {line}") # noqa: B904

Expand Down
2 changes: 1 addition & 1 deletion examples/run_downloadable_yaml_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
for yaml_connector in yaml_connectors:
try:
_ = get_source(yaml_connector, source_manifest=True)
except Exception as ex:
except Exception as ex: # noqa: PERF203
exception_type = type(ex).__name__
if exception_type in failed_installs:
failed_installs[exception_type].append(yaml_connector)
Expand Down
4 changes: 2 additions & 2 deletions tests/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ def test_pg_connection(host) -> bool:
conn = psycopg.connect(pg_url)
conn.close()
return True
except psycopg.OperationalError:
except psycopg.OperationalError: # noqa: PERF203
logger.info(
f"Waiting for postgres to start (attempt {attempt + 1}/{max_attempts})"
)
Expand Down Expand Up @@ -199,7 +199,7 @@ def new_postgres_db():
try:
postgres.reload()
postgres_is_running = postgres.status == "running"
except docker.errors.NotFound:
except docker.errors.NotFound: # noqa: PERF203
attempts -= 1
time.sleep(3)
if not postgres_is_running:
Expand Down
Loading