Purple Experience Builder
The pipelines are executed on the instance that received the file upload/change. There will be a maximum of concurrent pipelines and also a timeout for pipelines to not block the server forever.
An instance of a pipeline (called Job) is executed in a worker thread to not block the main thread responding to API requests etc.
flowchart TB
filechange(File change)
writetodisk(Write to disk)
filechange-->writetodisk
isinput{Is pipeline input?}
emitFileChange(Emit file change)
writetodisk-->isinput
Websocket([Client Websocket])
subgraph Pipeline management
direction RL
cancelExisitng(Cancel existing)
subgraph Workerthread[worker thread]
direction BT
startPipeline(Start pipeline)
updateStatus(Update logs/status)
finishPipeline(finish)
startPipeline-->updateStatus
updateStatus-->finishPipeline
end
cancelExisitng--input-->Workerthread
end
isinput--yes-->cancelExisitng
isinput--no: original file-->emitFileChange
finishPipeline-- output -->emitFileChange
updateStatus-->Websocket
emitFileChange-->Websocket
startPipeline-->Websocket