diff --git a/src/eo_processing/utils/jobmanager.py b/src/eo_processing/utils/jobmanager.py index 9e74897..4b75d89 100644 --- a/src/eo_processing/utils/jobmanager.py +++ b/src/eo_processing/utils/jobmanager.py @@ -502,6 +502,8 @@ def _launch_job(self, start_job, df, i, backend_name, stats: Optional[Dict] = No # start job if not yet done by callback try: job_con = job.connection + # Proactively refresh bearer token (because task in thread will not be able to do that) + self._refresh_bearer_token(connection=job_con) task = _JobStartTask( root_url=job_con.root_url, bearer_token=job_con.auth.bearer if isinstance(job_con.auth, BearerAuth) else None,