Atrifact ingest pipeline work

This commit is contained in:
Richard Cordovano 2021-05-28 15:09:35 -04:00
parent 1c2241285b
commit 2ba9a67dbe

View File

@ -69,24 +69,20 @@ public final class IngestJobContext {
} }
/** /**
* Queries whether or not cancellation of the data source ingest part of the * Indicates whether or not cancellation of the ingest job has been
* ingest job associated with this context has been requested. * requested.
* *
* @return True or false. * @return True or false.
*
* @deprecated Use dataSourceIngestIsCancelled() or fileIngestIsCancelled()
* instead.
*/ */
@Deprecated
public boolean isJobCancelled() { public boolean isJobCancelled() {
return dataSourceIngestIsCancelled(); return ingestJobPipeline.isCancelled();
} }
/** /**
* Checks whether or not cancellation of the currently running data source * Indicates whether or not cancellation of the currently running data
* level ingest module for the ingest job has been requested. Data source * source level ingest module has been requested. Data source level ingest
* level ingest modules should check this periodically and break off * modules should check this periodically and break off processing if the
* processing if the method returns true. * method returns true.
* *
* @return True or false. * @return True or false.
*/ */
@ -95,18 +91,16 @@ public final class IngestJobContext {
} }
/** /**
* Checks whether or not cancellation of the currently running file ingest * Indicates whether or not cancellation of the currently running file level
* module for the ingest job has been requested. File ingest modules should * ingest module has been requested. File level ingest modules should check
* check this periodically and break off processing if the method returns * this periodically and break off processing if the method returns true.
* true.
* *
* @return True or false. * @return True or false.
*/ */
public boolean fileIngestIsCancelled() { public boolean fileIngestIsCancelled() {
/* /*
* It is not currently possible to cancel individual file ingest * It is not currently possible to cancel individual file ingest
* modules. File ingest cancellation is equiovalent to ingest job * modules.
* cancellation.
*/ */
return ingestJobPipeline.isCancelled(); return ingestJobPipeline.isCancelled();
} }
@ -121,9 +115,8 @@ public final class IngestJobContext {
*/ */
public boolean dataArtifactIngestIsCancelled() { public boolean dataArtifactIngestIsCancelled() {
/* /*
* It is not currently possible to cancel individual file ingest * It is not currently possible to cancel individual data artifact
* modules. Data artifact ingest cancellation is equivalent to ingest * ingest modules.
* job cancellation.
*/ */
return ingestJobPipeline.isCancelled(); return ingestJobPipeline.isCancelled();
} }