Package com.netflix.genie.web.services.impl

Class ArchivedJobServiceImpl

java.lang.Object

com.netflix.genie.web.services.impl.ArchivedJobServiceImpl

All Implemented Interfaces:

ArchivedJobService

public class ArchivedJobServiceImpl
extends Object
implements ArchivedJobService

Default implementation of ArchivedJobService.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
ArchivedJobServiceImpl(DataServices dataServices, org.springframework.core.io.ResourceLoader resourceLoader, io.micrometer.core.instrument.MeterRegistry meterRegistry)	Constructor.

Method Summary

Modifier and Type	Method	Description
ArchivedJobMetadata	getArchivedJobMetadata(String jobId)	Retrieve the metadata about the contents and location of a jobs archived artifacts.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ArchivedJobServiceImpl

public ArchivedJobServiceImpl(DataServices dataServices,
 org.springframework.core.io.ResourceLoader resourceLoader,
 io.micrometer.core.instrument.MeterRegistry meterRegistry)

Constructor.

Parameters:

dataServices - The DataServices instance to use

resourceLoader - The ResourceLoader used to get resources

meterRegistry - The MeterRegistry used to collect metrics

Method Details

getArchivedJobMetadata

@Cacheable(cacheNames="archivedJobMetadata",
           sync=true)
@Retryable(maxAttemptsExpression="#{${genie.retry.archived-job-get-metadata.noOfRetries:5}}",
           include=JobDirectoryManifestNotFoundException.class,
           backoff=@Backoff(delayExpression="#{${genie.retry.archived-job-get-metadata.initialDelay:1000}}",multiplierExpression="#{${genie.retry.archived-job-get-metadata.multiplier:2.0}}"))
public ArchivedJobMetadata getArchivedJobMetadata(String jobId)
                                           throws JobNotFoundException,
JobNotArchivedException,
JobDirectoryManifestNotFoundException

Retrieve the metadata about the contents and location of a jobs archived artifacts.

Specified by:

getArchivedJobMetadata in interface ArchivedJobService

Parameters:

jobId - The id of the job

Returns:

A ArchivedJobMetadata instance

Throws:

JobNotFoundException - When no job with id jobId is found in the system

JobNotArchivedException - If the job wasn't archived so no manifest could be retrieved

JobDirectoryManifestNotFoundException - If the job was archived but the manifest can't be located