Skip to content

Initial version of 'live' processing service - #87

Open
iain-hall wants to merge 3 commits into
mainfrom
processing-service
Open

Initial version of 'live' processing service#87
iain-hall wants to merge 3 commits into
mainfrom
processing-service

Conversation

@iain-hall

Copy link
Copy Markdown
Contributor

Classes to implement 'live data processing' service. Data is read from a 'source' Hdf file, processed, and output to a new file. This takes place 'live' while the source data is still being written using SWMR mode to access Hdf file.

  • data_processor.py - classes to read, write Hdf files and process data
  • api.py - FastApi interface to data_processor functionality
  • api_client.py - client side code for using FastApi interface.
  • api_models.py - Pydantic models using in api layer.
  • Dockerfile.processing - builds a minimal container to run the service.

data_processor.py - classes to read, write Hdf files and process data
api.py - FastApi interface to data_processor functionality
api_client.py - client side code for using FastApi interface.
api_models.py - Pydantic models using in api layer.
Dockerfile.processing - builds a minimal container  to run the service.
@codecov

codecov Bot commented Jun 26, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 0% with 399 lines in your changes missing coverage. Please review.
✅ Project coverage is 19.31%. Comparing base (a6e3c04) to head (3b46993).
⚠️ Report is 2 commits behind head on main.

Files with missing lines Patch % Lines
...luesky/common/processing_service/data_processor.py 0.00% 257 Missing ⚠️
...ctroscopy_bluesky/common/processing_service/api.py 0.00% 86 Missing ⚠️
...py_bluesky/common/processing_service/api_client.py 0.00% 41 Missing ⚠️
...py_bluesky/common/processing_service/api_models.py 0.00% 11 Missing ⚠️
...copy_bluesky/common/processing_service/__init__.py 0.00% 4 Missing ⚠️
Additional details and impacted files
@@            Coverage Diff             @@
##             main      #87      +/-   ##
==========================================
- Coverage   28.35%   19.31%   -9.04%     
==========================================
  Files          21       26       +5     
  Lines         857     1258     +401     
==========================================
  Hits          243      243              
- Misses        614     1015     +401     

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

- HdfDatasource now checks to make sure read data matches requested shape, and reshapes it if necessary.
- Allow  multiple data sources (hdf files) to be used for each processing job.
- Removed circular dependency by using BaseModel instead of ProcessorSetup for setup type  in ProcessingClient#start_processor
- Added hdf5-tools and system utilities to docker file.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant