Share via

rxCleanupJobs: Cleanup of a Distributed Computing Job or Jobs.

  • Article

Description

Removes artifacts created while executing a distributed computing job.

Usage

  rxCleanupJobs(jobInfoList, force = FALSE, verbose = TRUE)

Arguments

jobInfoList

rxJobInfo object or a list of job objects that can be obtained from rxGetJobs.

force

logical scalar. If TRUE, forces removal of job directories even if there are retrievable results or if the current job state is undetermined.

verbose

logical scalar. If TRUE, will print the directories/records being deleted.

Details

If jobInfoList is a jobInfo object, rxCleanupJobs attempts to remove the artifacts. However, if the job has successfully completed and force=FALSE, rxCleanupJobs issues a warning saying to either set force=TRUE or use rxGetJobResults to get the results and delete the artifacts.

If jobInfoList is a list of jobs, rxCleanupJobs attempts to apply the cleanup rules for a single job to each element in the list.

Value

This function is called for its side effects (removing job artifacts); it does not have a useful return value.

Author(s)

Microsoft Corporation Microsoft Technical Support

See Also

rxGetJobs, rxGetJobOutput, RxSpark, RxHadoopMR, rxGetJobResults

Examples


 ## Not run:

rxCleanupJobs(jobInfoList = myJobs, force = TRUE)

rxCleanupJobs(rxGetJobs(rxGetOption("computeContext")))
## End(Not run)