com.netflix.genie.web.tasks.node

Class DiskCleanupTask

java.lang.Object

com.netflix.genie.web.tasks.node.DiskCleanupTask

All Implemented Interfaces:

java.lang.Runnable

@ConditionalOnProperty(value="genie.tasks.databaseCleanup.enabled")
 @Component
public class DiskCleanupTask
extends java.lang.Object
implements java.lang.Runnable

This task runs on every Genie node and is responsible for cleaning up the local disk so that space can be recaptured.

Constructor Summary

Constructors

Constructor and Description
DiskCleanupTask(DiskCleanupProperties properties, org.springframework.scheduling.TaskScheduler scheduler, org.springframework.core.io.Resource jobsDir, JobSearchService jobSearchService, JobsProperties jobsProperties, org.apache.commons.exec.Executor processExecutor, com.netflix.spectator.api.Registry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
void	run() Checks the disk for jobs on this host.

Methods inherited from class java.lang.Object

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

Constructor Detail

DiskCleanupTask

@Autowired
public DiskCleanupTask(@NotNull
                                  DiskCleanupProperties properties,
                                  @Qualifier(value="genieTaskScheduler") @NotNull
                                  org.springframework.scheduling.TaskScheduler scheduler,
                                  @NotNull
                                  org.springframework.core.io.Resource jobsDir,
                                  @NotNull
                                  JobSearchService jobSearchService,
                                  @NotNull
                                  JobsProperties jobsProperties,
                                  @NotNull
                                  org.apache.commons.exec.Executor processExecutor,
                                  @NotNull
                                  com.netflix.spectator.api.Registry registry)
                           throws java.io.IOException

Constructor. Schedules this task to be run by the task scheduler.

Parameters:

properties - The disk cleanup properties to use.

scheduler - The scheduler to use to schedule the cron trigger.

jobsDir - The resource representing the location of the job directory

jobSearchService - The service to find jobs with

jobsProperties - The jobs properties to use

processExecutor - The process executor to use to delete directories

registry - The metrics registry

Throws:

java.io.IOException - When it is unable to open a file reference to the job directory

Method Detail

run

public void run()

Checks the disk for jobs on this host. Deletes any job directories that are older than the desired retention and are complete.

Specified by:

run in interface java.lang.Runnable