com.netflix.genie.web.tasks.leader

Class AgentJobCleanupTask

java.lang.Object

com.netflix.genie.web.tasks.GenieTask

com.netflix.genie.web.tasks.leader.LeadershipTask

com.netflix.genie.web.tasks.leader.AgentJobCleanupTask

All Implemented Interfaces:

java.lang.Runnable

public class AgentJobCleanupTask
extends LeadershipTask

Leader task that cleans up jobs whose agent crashed or disconnected.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
AgentJobCleanupTask(JobSearchService jobSearchService, JobPersistenceService jobPersistenceService, AgentCleanupProperties properties, io.micrometer.core.instrument.MeterRegistry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
long	getFixedRate() Get how long the system should wait between invoking the run() method of this task in milliseconds.
GenieTaskScheduleType	getScheduleType() Get the type of scheduling mechanism which should be used to schedule this task.
void	run()

Methods inherited from class com.netflix.genie.web.tasks.GenieTask

getFixedDelay, getTrigger

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentJobCleanupTask

public AgentJobCleanupTask(JobSearchService jobSearchService,
                           JobPersistenceService jobPersistenceService,
                           AgentCleanupProperties properties,
                           io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

jobSearchService - the job search service

jobPersistenceService - the job persistence service

properties - the task properties

registry - the metrics registry

Method Detail

run

public void run()

cleanup

public void cleanup()

Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.

Overrides:

cleanup in class LeadershipTask

getScheduleType

public GenieTaskScheduleType getScheduleType()

Get the type of scheduling mechanism which should be used to schedule this task.

Specified by:

getScheduleType in class GenieTask

Returns:

The schedule type

getFixedRate

public long getFixedRate()

Get how long the system should wait between invoking the run() method of this task in milliseconds.

Overrides:

getFixedRate in class GenieTask

Returns:

The period to wait between invocations of run for this task