nv_ingest.service.impl.ingest package#

Submodules#

nv_ingest.service.impl.ingest.redis_ingest_service module#

class nv_ingest.service.impl.ingest.redis_ingest_service.RedisIngestService( redis_hostname: str, redis_port: int, redis_task_queue: str, )[source]#

Bases: IngestServiceMeta

Submits Jobs to via Redis

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

static getInstance()[source]#: Static Access Method

async get_processing_cache( job_id: str, ) → List[ProcessingJob][source]#: Retrieve processing jobs data using simple key-value

async set_processing_cache( job_id: str, jobs_data: List[ProcessingJob], ) → None[source]#: Store processing jobs data using simple key-value

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#