Skip to content
Merged
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
Original file line number Diff line number Diff line change
Expand Up @@ -132,10 +132,9 @@ def _run_stale_bundle_cleanup():
)
if not check_interval or check_interval <= 0 or not AIRFLOW_V_3_0_PLUS:
# do not start bundle cleanup process
try:
with suppress(BaseException):
yield
finally:
return
return
from airflow.dag_processing.bundles.base import BundleUsageTrackingManager

log.info("starting stale bundle cleanup process")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1095,4 +1095,4 @@ async def fetch_container_logs_before_current_sec(
print(message_to_log)
else:
self.log.info("[%s] %s", container_name, message_to_log)
return now # Return the current time as the last log time to ensure logs from the current second are read in the next fetch.
return now # Return the current time as the last log time to ensure logs from the current second are read in the next fetch.
2 changes: 2 additions & 0 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -629,11 +629,13 @@ extend-select = [
"PGH004", # Use specific rule codes when using noqa
"PGH005", # Invalid unittest.mock.Mock methods/attributes/properties
"S101", # Checks use `assert` outside the test cases, test cases should be added into the exclusions
"SIM107", # Don't use `return` in `try`-`except` and `finally`
"SIM300", # Checks for conditions that position a constant on the left-hand side of the comparison
# operator, rather than the right-hand side.
"B004", # Checks for use of hasattr(x, "__call__") and replaces it with callable(x)
"B006", # Checks for uses of mutable objects as function argument defaults.
"B007", # Checks for unused variables in the loop
"B012", # Checks for `break`, `continue`, and `return` statements in `finally` blocks
"B017", # Checks for pytest.raises context managers that catch Exception or BaseException.
"B019", # Use of functools.lru_cache or functools.cache on methods can lead to memory leaks
"B028", # No explicit stacklevel keyword argument found
Expand Down
Loading