com.netflix.genie.web.tasks.node

Class DiskCleanupTask

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

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.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
DiskCleanupTask(@NotNull DiskCleanupProperties properties, @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 io.micrometer.core.instrument.MeterRegistry 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

public DiskCleanupTask(@NotNull
                       @NotNull DiskCleanupProperties properties,
                       @NotNull
                       @NotNull org.springframework.scheduling.TaskScheduler scheduler,
                       @NotNull
                       @NotNull org.springframework.core.io.Resource jobsDir,
                       @NotNull
                       @NotNull JobSearchService jobSearchService,
                       @NotNull
                       @NotNull JobsProperties jobsProperties,
                       @NotNull
                       @NotNull org.apache.commons.exec.Executor processExecutor,
                       @NotNull
                       @NotNull io.micrometer.core.instrument.MeterRegistry 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