nv_ingest.service.meta.ingest package#

Submodules#

nv_ingest.service.meta.ingest.ingest_service_meta module#

class nv_ingest.service.meta.ingest.ingest_service_meta.IngestServiceMeta[source]#

Bases: ABC

abstract async fetch_job(job_id: str)[source]#: Abstract method for fetching job from ingestion service based on job_id

abstract async get_processing_cache( job_id: str, ) → List[ProcessingJob][source]#: Abstract method for getting processing cache

abstract async set_processing_cache( job_id: str, jobs_data: List[ProcessingJob], ) → None[source]#: Abstract method for setting processing cache

abstract async submit_job( job_spec: MessageWrapper, trace_id: str, ) → str[source]#: Abstract method for submitting one or more jobs to the ingestion pipeline

Module contents#