package Ġru . ot us . service . utils Ċ Ċ import Ġru . ot us . cor . operation Ċ import Ġru . ot us . cor . pipeline Ċ import Ġru . ot us . model . context . Context Status Ċ import Ġru . ot us . model . context . Exchange Context Ċ Ċ val Ġcomplete Pipeline Ġ= Ġpipeline < Exchange Context > Ġ{ ĊĠĠĠ Ġoperation Ġ{ ĊĠĠĠĠĠĠĠ Ġstart If Ġ{ Ġstatus Ġin Ġset Of ( Context Status . RUNNING , ĠContext Status . FIN ISH ING ) Ġ} ĊĠĠĠĠĠĠĠ Ġexecute Ġ{ Ġstatus Ġ= ĠContext Status . SUCCESS Ġ} ĊĠĠĠ Ġ} ĊĠĠĠ Ġoperation Ġ{ ĊĠĠĠĠĠĠĠ Ġstart If Ġ{ Ġstatus Ġ!= ĠContext Status . SUCCESS Ġ} ĊĠĠĠĠĠĠĠ Ġexecute Ġ{ Ġstatus Ġ= ĠContext Status . ERROR Ġ} ĊĠĠĠ Ġ} Ċ } Ċ Ċ val Ġrunning Pipeline Ġ= Ġoperation < Exchange Context > Ġ{ ĊĠĠĠ Ġstart If Ġ{ Ġstatus Ġ== ĠContext Status . INIT Ġ} ĊĠĠĠ Ġexecute Ġ{ Ġstatus Ġ= ĠContext Status . RUNNING Ġ} Ċ } Ċ