Uploaded image for project: 'Configuration Persistence Service'
  1. Configuration Persistence Service
  2. CPS-2142

Spliting a data-job into sub-jobs forward those to dmi

XMLWordPrintable

    • Icon: Story Story
    • Resolution: Unresolved
    • Icon: Medium Medium
    • None
    • None
    • NCMP
    • None

      As part of the overall solution the NCMP should be capable of receiving Datajob requests from DCM and group them to forward to the revelant DMIs.

      This implementation involves receiving the requests, writing the algorithm to group the requests and the forwarding to the DMI interface.

       

      How To:

      1. Take in list of Datajob operations (alternateids)
      2. Map operation path to cm handle id using alternate id. ()
        1. POC
        2. Capture performance
      3. Look up DMI Service Name and DataProducerIdentifier. Two fields form a tuple that is composit key (extra class to combine them ProducerKey) 
      4. Send 1 request per ProducerKey to interface DMI-I-02 in DMI Plugin
      5. NCMP java interface will return Mono/Flux response object(as we are using webclient)

       

      Acceptance Criteria:

      1. Agree implementation proposal with Team
        1. Define scenarios and outcomes (1 FDN, 1 Action, 1 DMI) (1FDN, 2 Actions, 2 DMI)
      2. Get response with a number of subjobs with subjobids wrapped into webclient mono/flux response
        1. Agree with stakeholders
      3. Demo with minimum 2 stud DMIs (subjobids do not need to be unique)
      4. Groovy based acceptance test included

       

      Out of Scope

      • Error handling
      • Javadoc to be delivered with following user story

       

      Potential Subtask:

      1. Implementation Proposal
      2. Clarify structure of datajob and subjob (possible Java implementation)

            sourabh_sourabh Sourabh Sourabh
            egernug Gerard Nugent
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: