Skip to content

Modify lhcone

Modification workflow for a LHCOne subscription.

modify_lhcone()

Modify LHCOne subscription.

Source code in gso/workflows/l3_core_service/lhcone/modify_lhcone.py 
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
@workflow(
    "Modify LHCOne",
    initial_input_form=wrap_modify_initial_input_form(initial_input_form_generator),
    target=Target.MODIFY,
)
def modify_lhcone() -> StepList:
    """Modify LHCOne  subscription."""
    access_port_is_added = conditional(lambda state: state["operation"] == Operation.ADD)
    access_port_is_removed = conditional(lambda state: state["operation"] == Operation.REMOVE)
    access_port_is_modified = conditional(lambda state: state["operation"] == Operation.EDIT)

    return (
        begin
        >> store_process_subscription(Target.MODIFY)
        >> unsync
        >> access_port_is_added(create_new_sbp)
        >> access_port_is_removed(remove_old_sbp)
        >> access_port_is_modified(modify_existing_sbp)
        >> resync
        >> done
    )