Skip to content

State Model Evolution

Andre Merzky edited this page Mar 17, 2023 · 8 revisions

Unit states up to version 0.27:

NEW                     - created in    umgr
UNSCHEDULED             - passed  to    umgr scheduler, but not assigned to a pilot
PENDING_INPUT_STAGING   - passed  to    staging-in, assigned to a pilot, waiting for file staging
STAGING_INPUT           - picked  up by staging-in, transfering files (in umgr and/or agent)
PENDING_EXECUTION       - passed  to    agent scheduler, agent waiting to assign cores
SCHEDULING              - picked  up by agent scheduler, attempts to assign cores for execution
EXECUTING               - picked  up by agent exec worker, cu is consuming cores
PENDING_OUTPUT_STAGING  - passed  to    staging-out, execution done, waiting for file transfer
STAGING_OUTPUT          - picked  up by staging-out, transferring files  (in umgr and/or agent)
DONE                    - final
CANCELED                - final
FAILED                  - final

Unit states in version 0.28:

NEW                     - created in    umgr
UNSCHEDULED             - passed  to    umgr scheduler
SCHEDULING              - picked  up by umgr scheduler, assigning cu to a pilot
PENDING_INPUT_STAGING   - passed  to    staging-in, assigned to a pilot, waiting for file staging
STAGING_INPUT           - picked  up by staging-in, transfering files (in umgr and/or agent)
PENDING_EXECUTION       - passed  to    agent scheduler, agent waiting to assign cores
ALLOCATING              - picked  up by agent scheduler, attempts to assign cores for execution
EXECUTING               - picked  up by agent exec worker, cu is consuming cores
PENDING_OUTPUT_STAGING  - passed  to    staging-out, execution done, waiting for file transfer
STAGING_OUTPUT          - picked  up by staging-out, transferring files  (in umgr and/or agent)
DONE                    - final
CANCELED                - final
FAILED                  - final

Unit states after module refactoring:

NEW                          - created in    umgr
UMGR_SCHEDULING_PENDING      - passed  to    umgr  scheduler
UMGR_SCHEDULING              - picked  up by umgr  scheduler, assigning cu to a pilot
UMGR_STAGING_INPUT_PENDING   - passed  to    umgr  staging-in, pilot is assigned
UMGR_STAGING_INPUT           - picked  up by umgr  staging-in, performing file staging
AGENT_STAGING_INPUT_PENDING  - passed  to    agent staging-in
AGENT_STAGING_INPUT          - picked  up by agent staging-in, performing file staging
AGENT_SCHEDULING_PENDING     - passed  to    agent scheduler, agent did not assign cores
AGENT_SCHEDULING             - picked  up by agent scheduler, attempts to assign cores for execution
EXECUTING_PENDING            - passed  on to exec  worker, cores are assigned
EXECUTING                    - picked  up by exec  worker, cores are 'consumed'
AGENT_STAGING_OUTPUT_PENDING - passed  to    agent staging-out
AGENT_STAGING_OUTPUT         - picked  up by agent staging-out, performing file staging
UMGR_STAGING_OUTPUT_PENDING  - passed  to    umgr  staging-out
UMGR_STAGING_OUTPUT          - picked  up by umgr  staging-out, performing file staging
DONE                         - final
CANCELED                     - final
FAILED                       - final

Task states after Unit->Task renaming:

NEW                          - created in    tmgr
TMGR_SCHEDULING_PENDING      - passed  to    tmgr  scheduler
TMGR_SCHEDULING              - picked  up by tmgr  scheduler, assigning cu to a pilot
TMGR_STAGING_INPUT_PENDING   - passed  to    tmgr  staging-in, pilot is assigned
TMGR_STAGING_INPUT           - picked  up by tmgr  staging-in, performing file staging
AGENT_STAGING_INPUT_PENDING  - passed  to    agent staging-in
AGENT_STAGING_INPUT          - picked  up by agent staging-in, performing file staging
AGENT_SCHEDULING_PENDING     - passed  to    agent scheduler, agent did not assign cores
AGENT_SCHEDULING             - picked  up by agent scheduler, attempts to assign cores for execution
AGENT_EXECUTING_PENDING      - passed  on to exec  worker, cores are assigned
AGENT_EXECUTING              - picked  up by exec  worker, cores are 'consumed'
AGENT_STAGING_OUTPUT_PENDING - passed  to    agent staging-out
AGENT_STAGING_OUTPUT         - picked  up by agent staging-out, performing file staging
TMGR_STAGING_OUTPUT_PENDING  - passed  to    tmgr  staging-out
TMGR_STAGING_OUTPUT          - picked  up by tmgr  staging-out, performing file staging
DONE                         - final
CANCELED                     - final
FAILED                       - final

Explicit mapping:

 <= 0.27                | 0.28                   | after module refactoring     
------------------------|------------------------|------------------------------
 NEW                    | NEW                    | NEW                          
 UNSCHEDULED            | UNSCHEDULED            | UMGR_SCHEDULING_PENDING      
 -- "     --            | SCHEDULING             | UMGR_SCHEDULING              
 PENDING_INPUT_STAGING  | PENDING_INPUT_STAGING  | UMGR_STAGING_INPUT_PENDING   
 STAGING_INPUT          | STAGING_INPUT          | UMGR_STAGING_INPUT           
 -- "       --          | -- "       --          | AGENT_STAGING_INPUT_PENDING  
 -- "       --          | -- "       --          | AGENT_STAGING_INPUT          
 PENDING_EXECUTION      | PENDING_EXECUTION      | AGENT_SCHEDULING_PENDING     
 SCHEDULING             | ALLOCATING             | AGENT_SCHEDULING             
 -- "    --             | -- "    --             | EXECUTING_PENDING            
 EXECUTING              | EXECUTING              | EXECUTING                    
 PENDING_OUTPUT_STAGING | PENDING_OUTPUT_STAGING | AGENT_STAGING_OUTPUT_PENDING 
 STAGING_OUTPUT         | STAGING_OUTPUT         | AGENT_STAGING_OUTPUT         
 -- "        --         | -- "        --         | UMGR_STAGING_OUTPUT_PENDING  
 -- "        --         | -- "        --         | UMGR_STAGING_OUTPUT          
 DONE                   | DONE                   | DONE                         
 CANCELED               | CANCELED               | CANCELED                     
 FAILED                 | FAILED                 | FAILED                       
Clone this wiki locally