Use default metadata_strategy of job can't be mapped

This commit is contained in:
mvdbeek
2020-07-04 23:05:19 +02:00
parent ef08965501
commit a3080bb53d
+4 -1
View File
@@ -913,7 +913,10 @@ class JobWrapper(HasResourceParameters):
if use_persisted_destination:
self.job_runner_mapper.cached_job_destination = JobDestination(from_job=job)
# Wrapper holding the info required to restore and clean up from files used for setting metadata externally
metadata_strategy_override = self.get_destination_configuration('metadata_strategy', None)
try:
metadata_strategy_override = self.get_destination_configuration('metadata_strategy', None)
except JobMappingException:
metadata_strategy_override = None
if job.tasks:
metadata_strategy_override = "directory"
self.external_output_metadata = get_metadata_compute_strategy(self.app.config, job.id, metadata_strategy_override=metadata_strategy_override)