Details
-
Feature
-
Not Assigned
-
Data Processing
-
-
-
Team_YANDA
-
Sprint 3
-
-
-
-
3.5
Description
The purpose of this feature is to have a first version of an interface between the SDP evolutionary prototype and the DALiuGE execution framework. This interface includes the execution of one or many Processing Blocks, and potentially the management of their state transitions.
DALiuGE deals with Logical and Physical graphs only, and has no concept of a Processing Block as defined by the SKA. However, most conceptual components seem to be there for this interface to be provided:
- An SKA Processing Block describes the execution of a workflow with a given set of parameters.
- On the other hand DALiuGE executes Physical Graphs, which in turn (optionally, but not necessarily) are produced by translating a Logical Graph.
- These Logical Graphs have parameters that can be changed before translation.
- Thus, executing a PB can be roughly translated to the execution of a given Logical Graph with the given parameter set.
- DALiuGE knows when an execution has started, and can monitor when it has finished. These events can be interpreted as state changes of the PB under execution, so the appropriate action can take place to ensure the state transition (e.g., publish an event signaling the state change).
- DALiuGE already supports concurrent graph executions in the form of isolated "sessions", and thus execution of more than one PB at a time should be possible if needed.
Our SUMMIT demo software stack already has all the pieces necessary to demonstrate this interface at the end of the day as a system demo, allowing us to concentrate on the really new parts of the system that need to be developed.
Links:
- PB definition: https://confluence.skatelescope.org/display/SE/Processing+Block+Configuration
- Notes on PB definition: https://docs.google.com/document/d/139WuiayDQGWtYuPL-P5Vq5SiqH58Hvkf-l21D_3HpLU/edit#heading=h.ofvlvii5yn0g
- JIRA tickets related to PB discussions:
SP-52SARCH-242