Celery Tasks Python Module

Module that contains all the amqp tasks that support the ingest infrastructure.

exception pacifica.ingest.tasks.IngestException

Ingest class exception.

pacifica.ingest.tasks.ingest_check_tarfile(job_id, filepath)

Check the ingest tarfile and return state or set it properly.

pacifica.ingest.tasks.ingest_files(job_id, ingest_obj)

Ingest the files to the archive interface.

pacifica.ingest.tasks.ingest_metadata(job_id, meta)

Ingest metadata to the metadata service.

pacifica.ingest.tasks.ingest_metadata_parser(job_id, tar)

Ingest the metadata and set the state appropriately.

pacifica.ingest.tasks.ingest_policy_check(job_id, meta_str, authed_user)

Ingest check to validate metadata at policy.

pacifica.ingest.tasks.move_files(job_id, meta_obj)

Move the files to the archive interface.

pacifica.ingest.tasks.move_metadata_parser(job_id, metafile)

Ingest the metadata and set the state appropriately.

pacifica.ingest.tasks.validate_meta(meta_str, authed_user)

Validate metadata.