Merge ADO latest main into github #17
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
* `OnemlProcessorsPipelineOperationsServices.COLLECTION_TO_DICT` returns a pipeline with an in_collection and an output that exposes the collection as a dictionary. * `OnemlProcessorsPipelineOperationsServices.DICT_TO_COLLECTION` returns a pipeline with a dictionary input and an out_collection the entries of the input dictionary as collection entries. * `OnemlProcessorsPipelineOperationsServices.DUPLICATE_PIPELINE` takes a pipeline and returns a pipeline with multiple copies of it. * `OnemlProcessorsPipelineOperationsServices.EXPOSE_GIVEN_OUTPUTS` takes data (dict of outputs, dict of dict of out collections) and creates a pipeline that exposes that data as output. * `OnemlProcessorsPipelineOperationsServices.EXPOSE_PIPELINE_AS_OUTPUT` takes a pipeline, returns an identical pipeline except it has an additional output exposing the given pipeline. * `OnemlProcessorsPipelineOperationsServices.LOAD_INPUTS_SAVE_OUTPUTS` takes a pipeline with an in_collection called `inputs_to_load` and an out_collection called `outputs_to_save` and returns a pipeline that loads the requested inputs from uris, passes them to the original pipeline, then saves the requested outputs to uris. * `OnemlHabitatsPipelineOperationsServices.PUBLISH_OUTPUTS_AS_DATASET` takes a pipeline that loads and saves to/from uris and returns a pipeline that loads from datasets and publishes a dataset.
…atsCliDiContainer b/c cl... allow from oneml.habitats.immunocli import OnemlHabitatsCliDiContainer b/c cli di containers should be exposed
…ction. * Fix. * Tetst.
…as input_uris and output... test load_inputs_save_outputs when pipeline already has input_uris and output_uris
…atasets fix services in oneml.habitats.pipeline_operations._datasets
…/c it lower-cases datase... remove furl from oneml.habitats.pipeline_operations b/c it lower-cases dataset name in ampds://
…ris with empty path segments
* Refactors plugins into every component. * Adds hydra registry for pipeline providers. * Adds two_diamond tests building a pipeline in YAML using a python pipeline provider.
…RITE_USING_LOCAL_CACHE_F... expose BLOB_READ_USING_LOCAL_CACHE_FACTORY and BLOB_WRITE_USING_LOCAL_CACHE_FACTORY for use by other packages
* Adds `DuplicatePipelineConf` to be able to generate duplicate pipelines in YAML. * Adds three diamond as test case.
📝 (docs) Update documentation.
…vice DatasetBlobStoreBaseLocationService provides the blob locations for datasets published by oneml. It should read these from an installation level configuration, but at the moment has them hard coded. The container name used from production and non-production datasets outside notebooks is wrong. This PR hopefully fixes it.
fix get_relative_path when base_uri ends with /
📝 Update docs.
add test that verifies mypy screams when a service id is associated with a service that is a super-type of the declared service type
…pped and add tests. 🚸 Refactor pipeline input validation for optional inputs and add tests.
✨ Add pipeline drop_inputs and drop_outputs methods
…ut_uris test publish_outputs_as_dataset when there are no input_uris
Datasets published by oneml pipelines have a manifest.json at their root that maps output names to relative paths within the dataset.
Pipeline builders can read from uris using `OnemlProcessorsIoServices.READ_FROM_URI_PIPELINE_BUILDER`, which by itself uses `ReadFromUriProcessor`, that takes a uri and returns the read object.
This PR adds the following semantic to uris:
If the uri has a fragment (i.e. something that follows #) then it is assumed that (after removing the fragment) the uri points to a json file. The fragment is assumed to be a dot-seprated hierarchical key into the json. The value associated with the key should be either a relative path from the directory of the json, or an absolute uri.
Examples:
if `file:///path1/path2/index.json` holds:
```
links:
rel: path3/array.npy
abs: ampds://mydataset/
another_abs: ampds://mydataset/manifest.json#entry_uris.container1?namespace=mynamespace
```
and `ampds://mydataset/manifest.json` holds:
```
entry_uris:
container1: containers/container1
```
Then:
* `file:///path1/path2/index.json#links.rel` becomes `file:///path1/path2/path3/array.npy`
* `file:///path1/path2/index.json#links.abs` becomes `ampds://mydataset/`
* `file:///path1/path2/index.json#links.another_abs` becomes `ampds://mydataset/containers/container1?namespace=mynamespace`
The semantics are implemented in `ReadFromUriProcessor` and therefore applicable only to pipelines built directly or indirectly using `OnemlProcessorsIoServices.READ_FROM_URI_PIPELINE_BUILDER`.
…cs/oneml into jzazo/ado
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Pytest and mypy passing.