This is a template to use for implementing a new pipeline into the LOFAR rest API (https://github.com/EOSC-LOFAR/lofar_workflow_api).
-
Copy this template and rename the directories called "LOFAR_pipeline_template". Also replace "LOFAR_pipeline_template" in the setup.py. Replace it with a sensible name for your pipeline.
-
Implement the run_pipeline(observation, **kargs). This function should run the pipeline in the background in anyway you want. The kargs variable is a dict with the keys as given by the data/config.json file.
-
Edit the data/config.json file. It should contain all the parameters needed by the pipeline to run and their requirements.
-
Use pip install to install your pipeline python package for the rest API.
-
In the rest API alter the pipeline_administrator.py (https://github.com/EOSC-LOFAR/lofar_workflow_api/blob/master/lofar_workflow_api/api/pipeline_administrator.py) in the following way 4.1 Add your pipeline package to the import (e.g. import pipeline1, pipeline2, ) 4.2 Add your pipeline to the dict in the get_available_pipelines() function. E.g.:
def get_available_pipelines():
return {pipeline1.give_name(): pipeline1,
pipeline2.give_name(): pipeline2,
<your pipeline>.give_name(): <your pipeline>}