diff --git a/data_management/watch_files.py b/data_management/watch_files.py index 1227ada..cfdc782 100644 --- a/data_management/watch_files.py +++ b/data_management/watch_files.py @@ -97,6 +97,7 @@ def check_disk_space(self, source_dir, target_dir, package_id): f"Available: {self.format_size(available_space)}. Skipping.") logger.warning(error_msg) self.dlu_management.update_dlu_package(package_id, { "globus_dlu_status": f"Error: Insufficient disk space for package {package_id}" }) + self.dlu_management.set_dlu_package_error(package_id) return False logger.info(f"Package {package_id}: Space check passed. " @@ -108,6 +109,7 @@ def check_disk_space(self, source_dir, target_dir, package_id): error_msg = f"Error: Failed to check disk space for package {package_id}: {str(e)}" logger.error(error_msg) self.dlu_management.update_dlu_package(package_id, { "globus_dlu_status": error_msg }) + self.dlu_management.set_dlu_package_error(package_id) return False def get_directory_size(self, directory):