Group sequential executor jobs in Backblaze B2 backup agent (#171045)

This commit is contained in:
Nick Haghiri
2026-05-17 22:37:41 -04:00
committed by GitHub
parent 481965eb0d
commit e8d21e57b3
@@ -175,12 +175,13 @@ class BackblazeBackupAgent(BackupAgent):
"Attempting to delete partially uploaded backup file %s",
filename,
)
def _delete_uploaded_file() -> None:
"""Look up and delete the partially uploaded backup file."""
self._bucket.get_file_info_by_name(filename).delete()
try:
uploaded_main_file_info = await self._hass.async_add_executor_job(
self._bucket.get_file_info_by_name, filename
)
# pylint: disable-next=home-assistant-sequential-executor-jobs
await self._hass.async_add_executor_job(uploaded_main_file_info.delete)
await self._hass.async_add_executor_job(_delete_uploaded_file)
except B2Error:
_LOGGER.warning(
"Failed to clean up partially uploaded backup file %s;"
@@ -386,9 +387,12 @@ class BackblazeBackupAgent(BackupAgent):
metadata_file.file_name,
)
await self._hass.async_add_executor_job(file.delete)
# pylint: disable-next=home-assistant-sequential-executor-jobs
await self._hass.async_add_executor_job(metadata_file.delete)
def _delete_backup_files() -> None:
"""Delete the backup file and its metadata file."""
file.delete()
metadata_file.delete()
await self._hass.async_add_executor_job(_delete_backup_files)
self._invalidate_caches(
backup_id,