Skip to main content

dcm-processor-worker

dcm-processor-worker is the execution layer for queued jobs in the dcm-processor platform.

It is responsible for taking scheduled work and actually running the service code.

Role In The Bigger Picture

This module sits at the end of the scheduling chain.

The high-level flow is:

  1. DICOM data is ingested and stored
  2. the scheduler creates queued jobs
  3. worker consumers pick up those jobs
  4. this module executes the requested callback

So this package is the runtime engine that turns job definitions into actual code execution.

Main Responsibilities

1. Worker Type Registration

The package supports different worker implementations and registers them through WorkerManager.

Currently supported types include:

  • venv-based workers
  • Docker-based workers
  • the default local service execution path

2. Worker Installation

The module installs worker environments from package content.

This includes:

  • building or pulling Docker images
  • creating Python virtual environments
  • installing Python dependencies
  • storing worker-side support files

3. Job Execution

When a queued job is consumed, this module:

  • loads the job record
  • loads the service module artifact
  • prepares the runtime environment
  • injects service runtime env vars
  • executes the requested callback
  • returns the result or error payload

4. Pre/Post Service Hooks

The module also exposes entry points for:

  • pre-service execution
  • post-service execution

These are scheduled by the job scheduler around the main service jobs.

Key Internal Areas

  • dcm_processor_worker/manager.py
    • central worker dispatch and environment preparation
  • dcm_processor_worker/venv_worker.py
    • Python virtual environment worker implementation
  • dcm_processor_worker/docker_worker.py
    • Docker-based worker implementation
  • dcm_processor_worker/venv_worker_lib.py
    • venv creation and generated wrapper execution helpers
  • dcm_processor_worker/base.py
    • base worker contract

Dependencies On Other Modules

This module depends mainly on:

  • dcm-processor-db-provider
    • for job, service, and worker data plus component files
  • dcm-processor-utils
    • for shared helpers such as device and archive logic

It works directly with:

  • dcm-processor-job-scheduler
    • which creates the jobs this module executes
  • dcm-processor-service
    • which is the runtime helper layer available to executed service code

What This Module Is Not

This package is not:

  • the scheduler
  • the DICOM listener
  • the main CLI
  • the persistence layer

It is the execution runtime for scheduled processing work.

Summary

Use this module when you need to install or run worker environments for dcm-processor jobs.

It is the piece of the system that actually runs the processing callbacks defined by installed packages.

Release files for dcm-processor-worker 0.0.1

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for dcm-processor-worker 0.0.1
File Size Uploaded
dcm_processor_worker-0.0.1.tar.gz 13.1 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for dcm-processor-worker 0.0.1
File Interpreter ABI Platform
dcm_processor_worker-0.0.1-py3-none-any.whl Python 3 none any Details

Total release size: 28.4 kB

Release files / dcm_processor_worker-0.0.1.tar.gz

Download URL dcm_processor_worker-0.0.1.tar.gz
Size 13.1 kB
Tags Source
SHA-256 checksum
How to use checksums
77bba7fbbfcbe7b4e4076735c8ab2bec45bb7676dffefaf24ed0caffb4652e3f
BLAKE2b-256 checksum
How to use checksums
9c068671e03cc8c8e1c9d37923ebd9aecd4d87d3ba9b61c4dc45832759968f04
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/6.2.0 CPython/3.10.12

Release files / dcm_processor_worker-0.0.1-py3-none-any.whl

Download URL dcm_processor_worker-0.0.1-py3-none-any.whl
Size 15.3 kB
Tags Python 3
SHA-256 checksum
How to use checksums
b4db7d71804dc7e8fb2842c711239cf4362f2b7377a4d0549da606c52d91e5af
BLAKE2b-256 checksum
How to use checksums
0b0b10d801a8d849d1ea90d6d42d8419eb99a5f426f3598a51e1dbe56b96ff70
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/6.2.0 CPython/3.10.12

Release history Release notifications | RSS feed

This release

0.0.1 This release

2 release files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page