diff --git a/ganga/GangaDirac/Lib/Backends/DiracBase.py b/ganga/GangaDirac/Lib/Backends/DiracBase.py index 0b4e519bf3..687616ed65 100644 --- a/ganga/GangaDirac/Lib/Backends/DiracBase.py +++ b/ganga/GangaDirac/Lib/Backends/DiracBase.py @@ -1136,7 +1136,6 @@ async def finalise_failed_job(job): ) except Exception as err: raise GangaDiracError(str(err)) - @staticmethod async def complete_dirac_job(job): @@ -1327,7 +1326,7 @@ async def job_finalisation(job, updated_dirac_status): job.been_queued = True task = monitoring_component.loop.create_task( DiracBase._internal_job_finalisation(job, updated_dirac_status)) - + try: await task except GangaDiracError as err: @@ -1355,7 +1354,7 @@ async def job_finalisation(job, updated_dirac_status): logger.error("Unable to finalise job %s after %s retries due to error:\n%s" % (job.getFQID('.'), str(count), str(err))) job.force_status('failed') - raise + raise time.sleep(sleep_length)