From 18428085622528528862efc61a540bf32aacab59 Mon Sep 17 00:00:00 2001 From: Hans Vanrompay Date: Wed, 15 Jan 2025 20:46:40 +0100 Subject: [PATCH] refactoring --- openeo/extra/job_management/__init__.py | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/openeo/extra/job_management/__init__.py b/openeo/extra/job_management/__init__.py index a0596fcf7..464f8c4f5 100644 --- a/openeo/extra/job_management/__init__.py +++ b/openeo/extra/job_management/__init__.py @@ -643,18 +643,6 @@ def download_task(): downloader = Thread(target=download_task, daemon=True) downloader.start() - def _job_download(self, job, job_dir, row): - """ - Download the job's results and update the job status after the download completes. - """ - try: - # Start downloading the job's results - job.get_results().download_files(target=job_dir) - - except Exception as e: - # If the download fails, set the status to 'error' - _log.error(f"Error downloading job {job.job_id}: {e}") - def on_job_error(self, job: BatchJob, row): """ Handles jobs that stopped with errors. Can be overridden to provide custom behaviour.