Skip to content

Commit

Permalink
add link to discussions
Browse files Browse the repository at this point in the history
  • Loading branch information
blankdots committed Apr 10, 2024
1 parent 694377f commit d7ad2d7
Showing 1 changed file with 27 additions and 5 deletions.
32 changes: 27 additions & 5 deletions docs/submission.md
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ Structure of the message and its contents are described in
SDA RabbitMQ-->>Intercept: Intercept reads message
Intercept -->> SDA RabbitMQ: Forwards ingest message <br/> to queue
alt Ingest is successful
Intercept->>Ingest: msg: [sda][ingest] begin ingestion
SDA RabbitMQ->>Ingest: msg: [sda][ingest] begin ingestion
activate Ingest
Ingest->>SDA Database: mark ingested
Note over Ingest: store file in Archive
Expand All @@ -68,7 +68,7 @@ Structure of the message and its contents are described in
Central EGA RabbitMQ-->>SDA RabbitMQ: federated msg: [from_cega][accession type]
SDA RabbitMQ-->>Intercept: Intercept reads message
Intercept -->> SDA RabbitMQ: Forwards accession ID message <br/> to queue
Intercept->>Finalize: msg: [sda][accession] map file to accession ID
SDA RabbitMQ->>Finalize: msg: [sda][accession] map file to accession ID
alt Finalize is successful
activate Finalize
note right of Finalize: Finalize makes the file backup
Expand All @@ -82,16 +82,38 @@ Structure of the message and its contents are described in
SDA RabbitMQ-->>Central EGA RabbitMQ: shovel msg:[to_cega][files.completed]
Central EGA RabbitMQ-->>SDA RabbitMQ: federated msg: [from_cega][mappings type]
SDA RabbitMQ-->>Intercept: Intercept reads message
Intercept -->> SDA RabbitMQ: Forwards mapper message <br/> to queue
Intercept->>Mapper: msg: [sda][mappings] begin ingestion
alt Mapper is successful
Intercept -->> SDA RabbitMQ: Forwards mapper message of type mapping <br/> to queue
SDA RabbitMQ->>Mapper: msg: [sda][mappings] map dataset to file accession ID
alt Mapper Mapper is creates dataset ID to file accession ID mapping
activate Mapper
Mapper->>SDA Database: map file to dataset accession ID
Mapper->>Inbox: remove file from inbox
else Error occurred in mapper process
Mapper-->>SDA RabbitMQ: msg: error
SDA RabbitMQ-->>Central EGA RabbitMQ: shovel msg:[to_cega][files.error]
end
Central EGA RabbitMQ-->>SDA RabbitMQ: federated msg: [from_cega][release type]
SDA RabbitMQ-->>Intercept: Intercept reads message
Intercept -->> SDA RabbitMQ: Forwards mapper message <br/> to queue
SDA RabbitMQ->>Mapper: msg: [sda][mappings] release dataset
alt Mapper flags dataset ready for release
activate Mapper
Mapper->>SDA Database: flag dataset ready for release
else Error occurred in mapper process
Mapper-->>SDA RabbitMQ: msg: error
SDA RabbitMQ-->>Central EGA RabbitMQ: shovel msg:[to_cega][files.error]
end
Central EGA RabbitMQ-->>SDA RabbitMQ: federated msg: [from_cega][deprecate type]
SDA RabbitMQ-->>Intercept: Intercept reads message
Intercept -->> SDA RabbitMQ: Forwards mapper message <br/> to queue
SDA RabbitMQ->>Mapper: msg: [sda][mappings] deprecate dataset
alt Mapper flags dataset as deprecated
activate Mapper
Mapper->>SDA Database: flag dataset as deprecated
else Error occurred in mapper process
Mapper-->>SDA RabbitMQ: msg: error
SDA RabbitMQ-->>Central EGA RabbitMQ: shovel msg:[to_cega][files.error]
end
deactivate Mapper
```
Expand Down

0 comments on commit d7ad2d7

Please sign in to comment.