nv_ingest.framework.util.service.meta.ingest package#

Submodules#

nv_ingest.framework.util.service.meta.ingest.ingest_service_meta module#

class nv_ingest.framework.util.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_fetch_mode() → FetchMode[source]#: Abstract method for getting fetch mode

abstract async get_job_state(job_id: str) → str | None[source]#: Abstract method for getting job state

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

abstract async set_job_state( job_id: str, state: str, ttl: int = 86400, )[source]#: Abstract method for setting job state

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#